[FLINK-15688] Add N-Ary Stream Operator in Flink

• Type: New Feature
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.10.0
• Fix Version/s: 1.11.0
• Component/s: API / DataStream, Runtime / Task
• Assignee: Piotr Nowojski
• Reporter: Piotr Nowojski
• Created: 20/Jan/20 14:23
• Updated: 28/Jul/20 07:21
• Resolved: 28/Jul/20 07:19

Description

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:

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)
}

Issue Links

• relates to: FLINK-18736 Source chaining with N-Ary Stream Operator in Flink