pyflink.table.table_environment.StreamTableEnvironment.create_statement_set#

StreamTableEnvironment.create_statement_set() → StatementSet#

Create a StatementSet instance which accepts DML statements or Tables, the planner can optimize all added statements and Tables together and then submit as one job.

:return statement_set instance