pyflink.table.table_environment.StreamTableEnvironment.execute_sql

StreamTableEnvironment.execute_sql(stmt: str) → pyflink.table.table_result.TableResult

Execute the given single statement, and return the execution result.

The statement can be DDL/DML/DQL/SHOW/DESCRIBE/EXPLAIN/USE. For DML and DQL, this method returns TableResult once the job has been submitted. For DDL and DCL statements, TableResult is returned once the operation has finished.

:return content for DQL/SHOW/DESCRIBE/EXPLAIN,

the affected row count for DML (-1 means unknown), or a string message (“OK”) for other statements.

New in version 1.11.0.