Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-15688

Add N-Ary Stream Operator in Flink

    XMLWordPrintableJSON

    Details

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

        Attachments

          Activity

            People

            • Assignee:
              pnowojski Piotr Nowojski
              Reporter:
              pnowojski Piotr Nowojski
            • Votes:
              0 Vote for this issue
              Watchers:
              9 Start watching this issue

              Dates

              • Created:
                Updated:

                Time Tracking

                Estimated:
                Original Estimate - Not Specified
                Not Specified
                Remaining:
                Remaining Estimate - 0h
                0h
                Logged:
                Time Spent - 1h 10m
                1h 10m