Details
-
Improvement
-
Status: Closed
-
Major
-
Resolution: Implemented
-
None
Description
Support to run a sql query : 'SELECT * FROM (VALUES (1, 2, 3)) T(a, b, c)', including:
1. add writeToSink, translateNodeDag in batch and stream tableEnv
2. introduce SinkRules for batch and stream
3. Introduce subclass of TableSink, including BaseUpsertStreamTableSink, BatchTableSink, CollectTableSink, DataStreamTableSink
4. StreamExecSink/BatchExecSink implements ExecNode interface
5. StramExecValues/BatchExecValues implements ExecNode interface, add CodeGen for Values.
6. add Itcase test infrastructure, add Itcase to run SELECT * FROM (VALUES (1, 2, 3)) T(a, b, c)' for batch and stream
Attachments
Issue Links
- is a child of
-
FLINK-11488 Add a basic Blink planner framework
- Closed
- links to