SQL Statements

CREATE / ALTER / INSERT / DROP statements can modify objects in a catalog. They can be 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");
...