@Internal public class FinishedOperatorChain<OUT,OP extends StreamOperator<OUT>> extends OperatorChain<OUT,OP>
OperatorChain that is used for restoring tasks that are TaskStateManager.isTaskDeployedAsFinished().OperatorChain.ChainedSourcechainedSources, closer, finishedOnRestoreInput, firstOperatorWrapper, isClosed, mainOperatorOutput, mainOperatorWrapper, numOperators, operatorEventDispatcher, streamOutputs, tailOperatorWrapper| Constructor and Description |
|---|
FinishedOperatorChain(StreamTask<OUT,OP> containingTask,
RecordWriterDelegate<SerializationDelegate<StreamRecord<OUT>>> recordWriterDelegate) |
abortCheckpoint, alignedBarrierTimeout, broadcastEvent, broadcastEvent, close, closeAllOperators, flushOutputs, getAllOperators, getAllOperators, getChainedSource, getChainedSourceOutputs, getFinishedOnRestoreInputOrDefault, getMainOperator, getNumberOfOperators, getOperatorEventDispatcher, getSourceTaskInput, getSourceTaskInputs, getStreamOutputs, getTailOperator, sendAcknowledgeCheckpointEvent, snapshotChannelStatespublic FinishedOperatorChain(StreamTask<OUT,OP> containingTask, RecordWriterDelegate<SerializationDelegate<StreamRecord<OUT>>> recordWriterDelegate)
public boolean isTaskDeployedAsFinished()
isTaskDeployedAsFinished in class OperatorChain<OUT,OP extends StreamOperator<OUT>>public WatermarkGaugeExposingOutput<StreamRecord<OUT>> getMainOperatorOutput()
getMainOperatorOutput in class OperatorChain<OUT,OP extends StreamOperator<OUT>>public void dispatchOperatorEvent(OperatorID operator, SerializedValue<OperatorEvent> event)
dispatchOperatorEvent in class OperatorChain<OUT,OP extends StreamOperator<OUT>>public void prepareSnapshotPreBarrier(long checkpointId)
prepareSnapshotPreBarrier in class OperatorChain<OUT,OP extends StreamOperator<OUT>>public void endInput(int inputId)
throws Exception
OperatorChaininputId).endInput in interface BoundedMultiInputendInput in class OperatorChain<OUT,OP extends StreamOperator<OUT>>inputId - the input ID starts from 1 which indicates the first input.Exceptionpublic void initializeStateAndOpenOperators(StreamTaskStateInitializer streamTaskStateInitializer)
OperatorChainStreamOperator.close() which happens heads to tail (see OperatorChain.finishOperators(StreamTaskActionExecutor, StopMode)).initializeStateAndOpenOperators in class OperatorChain<OUT,OP extends StreamOperator<OUT>>public void finishOperators(StreamTaskActionExecutor actionExecutor, StopMode stopMode) throws Exception
OperatorChainStreamOperator.open() which happens tail to
heads (see OperatorChain.initializeStateAndOpenOperators(StreamTaskStateInitializer)).finishOperators in class OperatorChain<OUT,OP extends StreamOperator<OUT>>Exceptionpublic void notifyCheckpointComplete(long checkpointId)
throws Exception
notifyCheckpointComplete in class OperatorChain<OUT,OP extends StreamOperator<OUT>>Exceptionpublic void notifyCheckpointAborted(long checkpointId)
throws Exception
notifyCheckpointAborted in class OperatorChain<OUT,OP extends StreamOperator<OUT>>Exceptionpublic void notifyCheckpointSubsumed(long checkpointId)
throws Exception
notifyCheckpointSubsumed in class OperatorChain<OUT,OP extends StreamOperator<OUT>>Exceptionpublic boolean isClosed()
isClosed in class OperatorChain<OUT,OP extends StreamOperator<OUT>>public void snapshotState(Map<OperatorID,OperatorSnapshotFutures> operatorSnapshotsInProgress, CheckpointMetaData checkpointMetaData, CheckpointOptions checkpointOptions, java.util.function.Supplier<Boolean> isRunning, ChannelStateWriter.ChannelStateWriteResult channelStateWriteResult, CheckpointStreamFactory storage) throws Exception
snapshotState in class OperatorChain<OUT,OP extends StreamOperator<OUT>>ExceptionCopyright © 2014–2023 The Apache Software Foundation. All rights reserved.