[
https://issues.apache.org/jira/browse/FLINK-11875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haibo Sun updated FLINK-11875:
------------------------------
Description:
Towards the goal that unify Streaming and Batch, this jira proposes enhanced
stream operator api to support selective reading and EndOfInput event for
currently Batch’s requirements.
Design Doc:
[https://docs.google.com/document/d/10k5pQm3SkMiK5Zn1iFDqhQnzjQTLF0Vtcbc8poB4_c8/edit?usp=sharing|http://example.com/]
Discussion Mail:
[http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/DISCUSS-Enhance-Operator-API-to-Support-Dynamically-Selective-Reading-and-EndOfInput-Event-td26753.html|http://example.com/]
was:
Towards the goal that unify Streaming and Batch, this jira proposes enhanced
stream operator api to support selective reading and EndOfInput event.
Design Doc:
[https://docs.google.com/document/d/10k5pQm3SkMiK5Zn1iFDqhQnzjQTLF0Vtcbc8poB4_c8/edit?usp=sharing|http://example.com/]
Discussion Mail:
[http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/DISCUSS-Enhance-Operator-API-to-Support-Dynamically-Selective-Reading-and-EndOfInput-Event-td26753.html|http://example.com/]
> Enhance stream operator API to support selective reading and EndOfInput event
> -----------------------------------------------------------------------------
>
> Key: FLINK-11875
> URL: https://issues.apache.org/jira/browse/FLINK-11875
> Project: Flink
> Issue Type: Improvement
> Components: Runtime / Operators
> Reporter: Haibo Sun
> Assignee: Haibo Sun
> Priority: Major
>
> Towards the goal that unify Streaming and Batch, this jira proposes enhanced
> stream operator api to support selective reading and EndOfInput event for
> currently Batch’s requirements.
> Design Doc:
> [https://docs.google.com/document/d/10k5pQm3SkMiK5Zn1iFDqhQnzjQTLF0Vtcbc8poB4_c8/edit?usp=sharing|http://example.com/]
> Discussion Mail:
> [http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/DISCUSS-Enhance-Operator-API-to-Support-Dynamically-Selective-Reading-and-EndOfInput-Event-td26753.html|http://example.com/]
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
