pyflink.table.table_environment.StreamTableEnvironment.create

static StreamTableEnvironment.create(stream_execution_environment: StreamExecutionEnvironment | None = None, environment_settings: EnvironmentSettings | None = None) → StreamTableEnvironment

Creates a StreamTableEnvironment.

Example:

# create with StreamExecutionEnvironment.
>>> env = StreamExecutionEnvironment.get_execution_environment()
>>> table_env = StreamTableEnvironment.create(env)
# create with StreamExecutionEnvironment and EnvironmentSettings.
>>> configuration = Configuration()
>>> configuration.set_string('execution.buffer-timeout', '1 min')
>>> environment_settings = EnvironmentSettings \
...     .new_instance() \
...     .in_streaming_mode() \
...     .with_configuration(configuration) \
...     .build()
>>> table_env = StreamTableEnvironment.create(
...     env, environment_settings=environment_settings)
# create with EnvironmentSettings.
>>> table_env = StreamTableEnvironment.create(environment_settings=environment_settings)

Parameters:

• stream_execution_environment – The StreamExecutionEnvironment of the TableEnvironment.

• environment_settings – The environment settings used to instantiate the TableEnvironment.

Returns:

The StreamTableEnvironment created from given StreamExecutionEnvironment and configuration.