All Methods Instance Methods Concrete Methods
Modifier and Type |
Method and Description |
void |
dispose() |
Object |
getCurrentKey() |
<K> KeyedStateBackend<K> |
getKeyedStateBackend() |
Optional<KeyedStateStore> |
getKeyedStateStore() |
OperatorStateBackend |
getOperatorStateBackend() |
<N,S extends State,T> S |
getOrCreateKeyedState(TypeSerializer<N> namespaceSerializer,
StateDescriptor<S,T> stateDescriptor) |
protected <S extends State,N> S |
getPartitionedState(N namespace,
TypeSerializer<N> namespaceSerializer,
StateDescriptor<S,?> stateDescriptor)
Creates a partitioned state handle, using the state backend configured for this task.
|
void |
initializeOperatorState(StreamOperatorStateHandler.CheckpointedStreamOperator streamOperator) |
void |
notifyCheckpointAborted(long checkpointId) |
void |
notifyCheckpointComplete(long checkpointId) |
void |
setCurrentKey(Object key) |
OperatorSnapshotFutures |
snapshotState(StreamOperatorStateHandler.CheckpointedStreamOperator streamOperator,
Optional<InternalTimeServiceManager<?>> timeServiceManager,
String operatorName,
long checkpointId,
long timestamp,
CheckpointOptions checkpointOptions,
CheckpointStreamFactory factory,
boolean isUsingCustomRawKeyedState) |