You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "godfrey he (JIRA)" <ji...@apache.org> on 2019/07/09 10:06:00 UTC
[jira] [Updated] (FLINK-13168) clarify
isBatch/isStreaming/isBounded flag in flink planner and blink planner
[ 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. {{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.
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. `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.
> 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. {{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)