pyflink.dataframe.get_or_create_table_environment

get_or_create_table_environment() → StreamTableEnvironment

Return the global TableEnvironment, creating and storing one if needed.

Buffered DataFrame config is applied when a new environment is created.