Table In Flink

1
// create a TableEnvironment for specific planner batch or streaming
2
TableEnvironment tableEnv = ...; // see "Create a TableEnvironment" section
3

4
// register a Table
5
tableEnv.registerTable("table1", ...)            // or
6
tableEnv.registerTableSource("table2", ...);     // or
7
// register an output Table
8
tableEnv.registerTableSink("outputTable", ...);
9

10
// create a Table from a Table API query
11
Table tapiResult = tableEnv.scan("table1").select(...);
12
// create a Table from a SQL query
13
Table sqlResult  = tableEnv.sqlQuery("SELECT ... FROM table2 ... ");
14

15
// emit a Table API result Table to a TableSink, same for SQL result
16
tapiResult.insertInto("outputTable");
17

18
// execute
19
tableEnv.execute("java_job");