pyflink.table.table_environment.StreamTableEnvironment.create#
- static StreamTableEnvironment.create(stream_execution_environment: Optional[pyflink.datastream.stream_execution_environment.StreamExecutionEnvironment] = None, environment_settings: Optional[pyflink.table.environment_settings.EnvironmentSettings] = None) pyflink.table.table_environment.StreamTableEnvironment [source]#
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.