[ https://issues.apache.org/jira/browse/FLINK-13168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
godfrey he updated FLINK-13168: ------------------------------- Description: 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. {{isBatch}} in {{TableSourceQueryOperation}}, which tells if the tableSource is {{BatchTableSource}} 3. {{isStreaming}} in {{TableSourceTable}}, which tells if if the current table is on stream planner 4. {{bounded StreamTableSource}} could be used for both batch and stream, while {{unbounded StreamTableSource}} could only be used for stream. was: 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. {{isBatch}} in {{TableSourceQueryOperation}}, , which tells if the tableSource is {{BatchTableSource}} 3. {{isStreaming}} in {{TableSourceTable}}, which tells if if the current table is on stream planner 4. {{bounded StreamTableSource}} could be used for both batch and stream, while {{unbounded StreamTableSource}} could only be used for stream. > 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 > Priority: Major > > 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. {{isBatch}} in {{TableSourceQueryOperation}}, which tells if the > tableSource is {{BatchTableSource}} > 3. {{isStreaming}} in {{TableSourceTable}}, which tells if if the current > table is on stream planner > 4. {{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)