- class TableConfig(j_table_config=None)[source]#
Configuration for the current
TableEnvironmentsession to adjust Table & SQL API programs.
This class is a pure API class that abstracts configuration from various sources. Currently, configuration can be set in any of the following layers (in the given order):
StreamExecutionEnvironmentwhen bridging to DataStream API
The latter two represent the application-specific part of the configuration. They initialize and directly modify
get_configuration(). Other layers represent the configuration of the execution context and are immutable.
get()gives read-only access to the full configuration. However, application-specific configuration has precedence. Configuration of outer layers is used for defaults and fallbacks. The setter
set()will only affect application-specific configuration.
For common or important configuration options, this class provides getters and setters methods with detailed inline documentation.
For more advanced configuration, users can directly access the underlying key-value map via
>>> table_config = t_env.get_config() >>> config = Configuration() >>> config.set_string("parallelism.default", "128") \ ... .set_string("pipeline.auto-watermark-interval", "800ms") \ ... .set_string("execution.checkpointing.interval", "30s") >>> table_config.add_configuration(config)
Because options are read at different point in time when performing operations, it is recommended to set configuration options early after instantiating a table environment.
Adds the given key-value configuration to the underlying configuration.
Returns the value associated with the given key as a string.
Gives direct access to the underlying key-value map for advanced configuration.
A TableConfig object with default settings.
The duration until state which was not updated will be retained.
Returns the local timezone id for timestamp with local time zone, either an abbreviation such as "PST", a full name such as "America/Los_Angeles", or a custom timezone_id such as "GMT-08:00".
The current threshold where generated code will be split into sub-function calls.
State will be cleared and removed if it was not updated for the defined period of time.
State might be cleared and removed if it was not updated for the defined period of time.
Gets the path of the python interpreter which is used to execute the python udf workers.
Returns the current SQL dialect.
Sets a string-based value for the given string-based key.
Specifies a retention time interval for how long idle state, i.e., state which was not updated, will be retained.
Specifies a minimum and a maximum time interval for how long idle state, i.e., state which was not updated, will be retained.
Sets the local timezone id for timestamp with local time zone.
Returns the current threshold where generated code will be split into sub-function calls.
Sets the path of the python interpreter which is used to execute the python udf workers.
Sets the current SQL dialect to parse a SQL query.