Package org.apache.flink.streaming.api.operators

Interface StreamOperatorStateHandler.CheckpointedStreamOperator

All Known Implementing Classes:

AbstractStreamOperator, AbstractStreamOperatorV2, AbstractUdfStreamOperator, AsyncWaitOperator, BatchCoBroadcastWithKeyedOperator, BatchCoBroadcastWithNonKeyedOperator, BatchGroupedReduceOperator, CacheTransformationTranslator.IdentityStreamOperator, CacheTransformationTranslator.NoOpStreamOperator, CoBroadcastWithKeyedOperator, CoBroadcastWithNonKeyedOperator, CollectSinkOperator, ContinuousFileReaderOperator, CoProcessOperator, CoStreamFlatMap, CoStreamMap, EvictingWindowOperator, GenericWriteAheadSink, IntervalJoinOperator, KeyedCoProcessOperator, KeyedProcessOperator, LegacyKeyedCoProcessOperator, LegacyKeyedProcessOperator, ProcessOperator, QueryableAppendingStateOperator, QueryableValueStateOperator, SourceOperator, StreamFilter, StreamFlatMap, StreamGroupedReduceOperator, StreamMap, StreamProject, StreamSink, StreamSource, TimestampsAndWatermarksOperator, WindowOperator

Enclosing class:

StreamOperatorStateHandler

public static interface StreamOperatorStateHandler.CheckpointedStreamOperator

Custom state handling hooks to be invoked by StreamOperatorStateHandler.

Method Summary

Modifier and Type	Method	Description
void	initializeState(org.apache.flink.runtime.state.StateInitializationContext context)
void	snapshotState(org.apache.flink.runtime.state.StateSnapshotContext context)

Method Detail

initializeState

void initializeState(org.apache.flink.runtime.state.StateInitializationContext context)
              throws Exception

Throws:

Exception

snapshotState

void snapshotState(org.apache.flink.runtime.state.StateSnapshotContext context)
            throws Exception

Throws:

Exception