Package | Description |
---|---|
org.apache.flink.runtime.state |
Modifier and Type | Method and Description |
---|---|
abstract DirectoryStateHandle |
SnapshotDirectory.completeSnapshotAndGetHandle()
Calling this method completes the snapshot for this snapshot directory, if possible, and
creates a corresponding
DirectoryStateHandle that points to the snapshot directory. |
DirectoryStateHandle |
DirectoryKeyedStateHandle.getDirectoryStateHandle() |
Constructor and Description |
---|
DirectoryKeyedStateHandle(DirectoryStateHandle directoryStateHandle,
KeyGroupRange keyGroupRange) |
IncrementalLocalKeyedStateHandle(UUID backendIdentifier,
long checkpointId,
DirectoryStateHandle directoryStateHandle,
KeyGroupRange keyGroupRange,
StreamStateHandle metaDataState,
Set<StateHandleID> sharedStateHandleIDs) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.