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

Interface StreamOperatorStateHandler.CheckpointedStreamOperator

All Known Implementing Classes:

AbstractAsyncStateStreamOperator, AbstractAsyncStateStreamOperatorV2, AbstractAsyncStateUdfStreamOperator, AbstractStreamOperator, AbstractStreamOperatorV2, AbstractUdfStreamOperator, AsyncWaitOperator, BatchCoBroadcastWithKeyedOperator, BatchCoBroadcastWithNonKeyedOperator, BatchGroupedReduceOperator, CacheTransformationTranslator.IdentityStreamOperator, CacheTransformationTranslator.NoOpStreamOperator, CoBroadcastWithKeyedOperator, CoBroadcastWithNonKeyedOperator, CollectSinkOperator, ContinuousFileReaderOperator, CoProcessOperator, CoStreamFlatMap, CoStreamMap, EvictingWindowOperator, GenericWriteAheadSink, GlobalCommitterOperator, IntervalJoinOperator, KeyedCoProcessOperator, KeyedProcessOperator, KeyedSortPartitionOperator, LegacyKeyedCoProcessOperator, LegacyKeyedProcessOperator, MapPartitionOperator, PartitionAggregateOperator, PartitionReduceOperator, ProcessOperator, QueryableAppendingStateOperator, QueryableValueStateOperator, SortPartitionOperator, 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