[jira] [Created] (FLINK-13168) clarify isBatch/isStreaming/isBounded flag in flink planner and blink planner

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-13168) clarify isBatch/isStreaming/isBounded flag in flink planner and blink planner

Shang Yuanchun (Jira)
godfrey he created FLINK-13168:
----------------------------------

             Summary: clarify isBatch/isStreaming/isBounded flag in flink planner and blink planner
                 Key: FLINK-13168
                 URL: https://issues.apache.org/jira/browse/FLINK-13168
             Project: Flink
          Issue Type: Improvement
          Components: Table SQL / Legacy Planner, Table SQL / Planner
            Reporter: godfrey he
            Assignee: godfrey he


in blink planner & flink planner, there are many `isBatch` and `isStreaming` flags, they have different meaning in different place. which makes reader and coder crazy. especially in blink planner, Only `StreamTableSource` could be used for both batch and stream. is `bounded StreamTableSource` means batch, `unbounded` means stream ?

we should make it clear:
1. `isBatch` in `ConnectorCatalogTable`, which tells if the tableSource/tableSink is BatchTableSource/BatchTableSink
2. `isStreaming` in `TableSourceTable`, which tells if  if the current table is on stream planner
3. `bounded StreamTableSource` could be used for both batch and stream, while `unbounded StreamTableSource` could only be used for stream.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)