pyflink.table.table_environment.TableEnvironment.create_statement_set#

TableEnvironment.create_statement_set() → pyflink.table.statement_set.StatementSet[source]#

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