public interface IncrementalKeyedStateHandle extends KeyedStateHandle, CheckpointBoundKeyedStateHandle
KeyedStateHandle
.Modifier and Type | Interface and Description |
---|---|
static class |
IncrementalKeyedStateHandle.HandleAndLocalPath
A Holder of StreamStateHandle and the corresponding localPath.
|
StateObject.StateObjectLocation, StateObject.StateObjectSizeStatsCollector
Modifier and Type | Method and Description |
---|---|
UUID |
getBackendIdentifier()
Returns the identifier of the state backend from which this handle was created.
|
StreamStateHandle |
getMetaDataStateHandle() |
List<IncrementalKeyedStateHandle.HandleAndLocalPath> |
getSharedStateHandles()
Returns a list of all shared states and the corresponding localPath in the backend at the
time this was created.
|
getCheckpointId, rebound
getIntersection, getKeyGroupRange, getStateHandleId
getCheckpointedSize, registerSharedStates
collectSizeStats, discardState, getStateSize
@Nonnull UUID getBackendIdentifier()
@Nonnull List<IncrementalKeyedStateHandle.HandleAndLocalPath> getSharedStateHandles()
@Nonnull StreamStateHandle getMetaDataStateHandle()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.