Piotr Nowojski created FLINK-15688: -------------------------------------- Summary: 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.11.0 Reporter: Piotr Nowojski Assignee: Piotr Nowojski
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)