SQL and Table APIPDF version

SQL Statements in Flink

You can use the CREATE / ALTER / INSERT / DROP statements to modify objects in the chosen catalog. The statements are executed with the sqlUpdate() method of the TableEnvironment.

...
StreamTableEnvironment tableEnv = StreamTableEnvironment.create(env, settings);
tableEnv.sqlUpdate("CREATE TABLE t1(c1 STRING) WITH (...)");
tableEnv.sqlUpdate("DROP TABLE t1");
...