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

Class OneInputStreamOperatorOutput

  • 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:
    CopyingOneInputStreamOperatorOutput
    public class OneInputStreamOperatorOutput
extends OutputBase
    An Output that can be used to emit elements and other messages for OneInputStreamOperator.

    • Constructor Summary

      Constructors 
      Constructor Description
      OneInputStreamOperatorOutput​(org.apache.flink.streaming.api.operators.OneInputStreamOperator<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 emitRecordAttributes​(org.apache.flink.streaming.runtime.streamrecord.RecordAttributes recordAttributes)  
      void emitWatermark​(org.apache.flink.runtime.event.WatermarkEvent watermark)  
      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

      • OneInputStreamOperatorOutput

        public OneInputStreamOperatorOutput​(org.apache.flink.streaming.api.operators.OneInputStreamOperator<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)

      • emitRecordAttributes

        public void emitRecordAttributes​(org.apache.flink.streaming.runtime.streamrecord.RecordAttributes recordAttributes)

      • emitWatermark

        public void emitWatermark​(org.apache.flink.runtime.event.WatermarkEvent watermark)

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