Package org.apache.flink.state.api.output.operators

Class StateBootstrapWrapperOperator<IN,​OUT,​OP extends org.apache.flink.streaming.api.operators.AbstractStreamOperator<OUT> & org.apache.flink.streaming.api.operators.OneInputStreamOperator<IN,​OUT>>

  • All Implemented Interfaces:
    Serializable, org.apache.flink.api.common.state.CheckpointListener, org.apache.flink.streaming.api.operators.BoundedOneInput, org.apache.flink.streaming.api.operators.Input<IN>, org.apache.flink.streaming.api.operators.KeyContext, org.apache.flink.streaming.api.operators.OneInputStreamOperator<IN,​TaggedOperatorSubtaskState>, org.apache.flink.streaming.api.operators.SetupableStreamOperator<TaggedOperatorSubtaskState>, org.apache.flink.streaming.api.operators.StreamOperator<TaggedOperatorSubtaskState>
    @Internal
public final class StateBootstrapWrapperOperator<IN,​OUT,​OP extends org.apache.flink.streaming.api.operators.AbstractStreamOperator<OUT> & org.apache.flink.streaming.api.operators.OneInputStreamOperator<IN,​OUT>>
extends Object
implements org.apache.flink.streaming.api.operators.OneInputStreamOperator<IN,​TaggedOperatorSubtaskState>, org.apache.flink.streaming.api.operators.SetupableStreamOperator<TaggedOperatorSubtaskState>, org.apache.flink.streaming.api.operators.BoundedOneInput
    Wraps an existing operator so it can be bootstrapped.
    See Also:
    Serialized Form

    • Constructor Summary

      Constructors 
      Constructor Description
      StateBootstrapWrapperOperator​(long timestamp, org.apache.flink.core.fs.Path savepointPath, OP operator)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void close()  
      void endInput()  
      void finish()  
      org.apache.flink.streaming.api.operators.ChainingStrategy getChainingStrategy()  
      Object getCurrentKey()  
      org.apache.flink.metrics.groups.OperatorMetricGroup getMetricGroup()  
      org.apache.flink.runtime.jobgraph.OperatorID getOperatorID()  
      void initializeState​(org.apache.flink.streaming.api.operators.StreamTaskStateInitializer streamTaskStateManager)  
      void notifyCheckpointComplete​(long checkpointId)  
      void open()  
      void prepareSnapshotPreBarrier​(long checkpointId)  
      void processElement​(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IN> element)  
      void processLatencyMarker​(org.apache.flink.streaming.runtime.streamrecord.LatencyMarker latencyMarker)  
      void processWatermark​(org.apache.flink.streaming.api.watermark.Watermark mark)  
      void processWatermarkStatus​(org.apache.flink.streaming.runtime.watermarkstatus.WatermarkStatus watermarkStatus)  
      void setChainingStrategy​(org.apache.flink.streaming.api.operators.ChainingStrategy strategy)  
      void setCurrentKey​(Object key)  
      void setKeyContextElement1​(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<?> record)  
      void setKeyContextElement2​(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<?> record)  
      void setup​(org.apache.flink.streaming.runtime.tasks.StreamTask<?,​?> containingTask, org.apache.flink.streaming.api.graph.StreamConfig config, org.apache.flink.streaming.api.operators.Output<org.apache.flink.streaming.runtime.streamrecord.StreamRecord<TaggedOperatorSubtaskState>> output)  
      org.apache.flink.streaming.api.operators.OperatorSnapshotFutures snapshotState​(long checkpointId, long timestamp, org.apache.flink.runtime.checkpoint.CheckpointOptions checkpointOptions, org.apache.flink.runtime.state.CheckpointStreamFactory storageLocation)  

      • Methods inherited from interface org.apache.flink.api.common.state.CheckpointListener

        notifyCheckpointAborted

      • Methods inherited from interface org.apache.flink.streaming.api.operators.Input

        processRecordAttributes

      • Methods inherited from interface org.apache.flink.streaming.api.operators.OneInputStreamOperator

        setKeyContextElement

      • Methods inherited from interface org.apache.flink.streaming.api.operators.StreamOperator

        getOperatorAttributes

    • Constructor Detail

      • StateBootstrapWrapperOperator

        public StateBootstrapWrapperOperator​(long timestamp,
                                     org.apache.flink.core.fs.Path savepointPath,
                                     OP operator)

    • Method Detail

      • setup

        public void setup​(org.apache.flink.streaming.runtime.tasks.StreamTask<?,​?> containingTask,
                  org.apache.flink.streaming.api.graph.StreamConfig config,
                  org.apache.flink.streaming.api.operators.Output<org.apache.flink.streaming.runtime.streamrecord.StreamRecord<TaggedOperatorSubtaskState>> output)
        Specified by:
        setup in interface org.apache.flink.streaming.api.operators.SetupableStreamOperator<IN>

      • processElement

        public void processElement​(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IN> element)
                    throws Exception
        Specified by:
        processElement in interface org.apache.flink.streaming.api.operators.Input<IN>
        Throws:
        Exception

      • processWatermark

        public void processWatermark​(org.apache.flink.streaming.api.watermark.Watermark mark)
                      throws Exception
        Specified by:
        processWatermark in interface org.apache.flink.streaming.api.operators.Input<IN>
        Throws:
        Exception

      • processLatencyMarker

        public void processLatencyMarker​(org.apache.flink.streaming.runtime.streamrecord.LatencyMarker latencyMarker)
                          throws Exception
        Specified by:
        processLatencyMarker in interface org.apache.flink.streaming.api.operators.Input<IN>
        Throws:
        Exception

      • processWatermarkStatus

        public void processWatermarkStatus​(org.apache.flink.streaming.runtime.watermarkstatus.WatermarkStatus watermarkStatus)
                            throws Exception
        Specified by:
        processWatermarkStatus in interface org.apache.flink.streaming.api.operators.Input<IN>
        Throws:
        Exception

      • open

        public void open()
          throws Exception
        Specified by:
        open in interface org.apache.flink.streaming.api.operators.StreamOperator<IN>
        Throws:
        Exception

      • finish

        public void finish()
            throws Exception
        Specified by:
        finish in interface org.apache.flink.streaming.api.operators.StreamOperator<IN>
        Throws:
        Exception

      • close

        public void close()
           throws Exception
        Specified by:
        close in interface org.apache.flink.streaming.api.operators.StreamOperator<IN>
        Throws:
        Exception

      • prepareSnapshotPreBarrier

        public void prepareSnapshotPreBarrier​(long checkpointId)
                               throws Exception
        Specified by:
        prepareSnapshotPreBarrier in interface org.apache.flink.streaming.api.operators.StreamOperator<IN>
        Throws:
        Exception

      • snapshotState

        public org.apache.flink.streaming.api.operators.OperatorSnapshotFutures snapshotState​(long checkpointId,
                                                                                      long timestamp,
                                                                                      org.apache.flink.runtime.checkpoint.CheckpointOptions checkpointOptions,
                                                                                      org.apache.flink.runtime.state.CheckpointStreamFactory storageLocation)
                                                                               throws Exception
        Specified by:
        snapshotState in interface org.apache.flink.streaming.api.operators.StreamOperator<IN>
        Throws:
        Exception

      • initializeState

        public void initializeState​(org.apache.flink.streaming.api.operators.StreamTaskStateInitializer streamTaskStateManager)
                     throws Exception
        Specified by:
        initializeState in interface org.apache.flink.streaming.api.operators.StreamOperator<IN>
        Throws:
        Exception

      • setKeyContextElement1

        public void setKeyContextElement1​(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<?> record)
                           throws Exception
        Specified by:
        setKeyContextElement1 in interface org.apache.flink.streaming.api.operators.StreamOperator<IN>
        Throws:
        Exception

      • setKeyContextElement2

        public void setKeyContextElement2​(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<?> record)
                           throws Exception
        Specified by:
        setKeyContextElement2 in interface org.apache.flink.streaming.api.operators.StreamOperator<IN>
        Throws:
        Exception

      • getChainingStrategy

        public org.apache.flink.streaming.api.operators.ChainingStrategy getChainingStrategy()
        Specified by:
        getChainingStrategy in interface org.apache.flink.streaming.api.operators.SetupableStreamOperator<IN>

      • setChainingStrategy

        public void setChainingStrategy​(org.apache.flink.streaming.api.operators.ChainingStrategy strategy)
        Specified by:
        setChainingStrategy in interface org.apache.flink.streaming.api.operators.SetupableStreamOperator<IN>

      • getMetricGroup

        public org.apache.flink.metrics.groups.OperatorMetricGroup getMetricGroup()
        Specified by:
        getMetricGroup in interface org.apache.flink.streaming.api.operators.StreamOperator<IN>

      • getOperatorID

        public org.apache.flink.runtime.jobgraph.OperatorID getOperatorID()
        Specified by:
        getOperatorID in interface org.apache.flink.streaming.api.operators.StreamOperator<IN>

      • notifyCheckpointComplete

        public void notifyCheckpointComplete​(long checkpointId)
                              throws Exception
        Specified by:
        notifyCheckpointComplete in interface org.apache.flink.api.common.state.CheckpointListener
        Throws:
        Exception

      • setCurrentKey

        public void setCurrentKey​(Object key)
        Specified by:
        setCurrentKey in interface org.apache.flink.streaming.api.operators.KeyContext

      • getCurrentKey

        public Object getCurrentKey()
        Specified by:
        getCurrentKey in interface org.apache.flink.streaming.api.operators.KeyContext

      • endInput

        public void endInput()
              throws Exception
        Specified by:
        endInput in interface org.apache.flink.streaming.api.operators.BoundedOneInput
        Throws:
        Exception