Package org.apache.flink.table.runtime.operators.multipleinput.output

Class FirstInputOfTwoInputStreamOperatorOutput

  • All Implemented Interfaces:
    org.apache.flink.streaming.api.operators.Output<org.apache.flink.streaming.runtime.streamrecord.StreamRecord<org.apache.flink.table.data.RowData>>, org.apache.flink.util.Collector<org.apache.flink.streaming.runtime.streamrecord.StreamRecord<org.apache.flink.table.data.RowData>>
    Direct Known Subclasses:
    CopyingFirstInputOfTwoInputStreamOperatorOutput
    public class FirstInputOfTwoInputStreamOperatorOutput
extends OutputBase
    An Output that can be used to emit elements and other messages for the first input of TwoInputStreamOperator.

    • Constructor Summary

      Constructors 
      Constructor Description
      FirstInputOfTwoInputStreamOperatorOutput​(org.apache.flink.streaming.api.operators.TwoInputStreamOperator<org.apache.flink.table.data.RowData,​org.apache.flink.table.data.RowData,​org.apache.flink.table.data.RowData> operator)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void collect​(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<org.apache.flink.table.data.RowData> record)  
      <X> void collect​(org.apache.flink.util.OutputTag<X> outputTag, org.apache.flink.streaming.runtime.streamrecord.StreamRecord<X> record)  
      void emitLatencyMarker​(org.apache.flink.streaming.runtime.streamrecord.LatencyMarker latencyMarker)  
      void emitWatermark​(org.apache.flink.streaming.api.watermark.Watermark mark)  
      void emitWatermarkStatus​(org.apache.flink.streaming.runtime.watermarkstatus.WatermarkStatus watermarkStatus)  
      protected <X> void pushToOperator​(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<X> record)  

      • Methods inherited from class org.apache.flink.table.runtime.operators.multipleinput.output.OutputBase

        close

    • Constructor Detail

      • FirstInputOfTwoInputStreamOperatorOutput

        public FirstInputOfTwoInputStreamOperatorOutput​(org.apache.flink.streaming.api.operators.TwoInputStreamOperator<org.apache.flink.table.data.RowData,​org.apache.flink.table.data.RowData,​org.apache.flink.table.data.RowData> operator)

    • Method Detail

      • emitWatermark

        public void emitWatermark​(org.apache.flink.streaming.api.watermark.Watermark mark)

      • emitWatermarkStatus

        public void emitWatermarkStatus​(org.apache.flink.streaming.runtime.watermarkstatus.WatermarkStatus watermarkStatus)

      • emitLatencyMarker

        public void emitLatencyMarker​(org.apache.flink.streaming.runtime.streamrecord.LatencyMarker latencyMarker)

      • collect

        public void collect​(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<org.apache.flink.table.data.RowData> record)

      • collect

        public <X> void collect​(org.apache.flink.util.OutputTag<X> outputTag,
                        org.apache.flink.streaming.runtime.streamrecord.StreamRecord<X> record)

      • pushToOperator

        protected <X> void pushToOperator​(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<X> record)