You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/01/20 14:32:00 UTC
[jira] [Updated] (FLINK-15688) Add N-Ary Stream Operator in Flink
[ https://issues.apache.org/jira/browse/FLINK-15688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Piotr Nowojski updated FLINK-15688:
-----------------------------------
Affects Version/s: (was: 1.11.0)
1.10.0
> Add N-Ary Stream Operator in Flink
> ----------------------------------
>
> Key: FLINK-15688
> URL: https://issues.apache.org/jira/browse/FLINK-15688
> Project: Flink
> Issue Type: New Feature
> Components: API / DataStream, Runtime / Task
> Affects Versions: 1.10.0
> Reporter: Piotr Nowojski
> Assignee: Piotr Nowojski
> Priority: Major
>
> As described here: https://cwiki.apache.org/confluence/display/FLINK/FLIP-92%3A+Add+N-Ary+Stream+Operator+in+Flink
> The plan is to provide an N-Ary Stream Operator with more or less the following interface:
> {code}
> abstract class StreamOperatorNG<OUT> {
> Collection<Input<?>> getInputs()
>
> // as well as all the other methods of existing StreamOperator
> // and AbstractStreamOperator:
> // setup()/open()/close()/snapshot()/restore() ...
> }
>
> abstract class Input<T> {
> // for determining whether two inputs are equal
> private final UUID uuid = UUID.randomUUID();
>
> public abstract void processElement(StreamRecord<T> element)
>
> public abstract void processWatermark(Watermark watermark)
> }
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)