Package | Description |
---|---|
org.apache.flink.runtime.state | |
org.apache.flink.runtime.state.changelog | |
org.apache.flink.runtime.state.changelog.inmemory |
Modifier and Type | Method and Description |
---|---|
StateHandleID |
IncrementalRemoteKeyedStateHandle.getStateHandleId() |
StateHandleID |
KeyGroupsStateHandle.getStateHandleId() |
StateHandleID |
DirectoryKeyedStateHandle.getStateHandleId() |
StateHandleID |
KeyedStateHandle.getStateHandleId()
Returns a unique state handle id to distinguish with other keyed state handles.
|
static StateHandleID |
StateHandleID.randomStateHandleId() |
Modifier and Type | Method and Description |
---|---|
static KeyGroupsStateHandle |
KeyGroupsStateHandle.restore(KeyGroupRangeOffsets groupRangeOffsets,
StreamStateHandle streamStateHandle,
StateHandleID stateHandleId) |
static IncrementalRemoteKeyedStateHandle |
IncrementalRemoteKeyedStateHandle.restore(UUID backendIdentifier,
KeyGroupRange keyGroupRange,
long checkpointId,
List<IncrementalKeyedStateHandle.HandleAndLocalPath> sharedState,
List<IncrementalKeyedStateHandle.HandleAndLocalPath> privateState,
StreamStateHandle metaStateHandle,
long persistedSizeOfThisCheckpoint,
StateHandleID stateHandleId) |
Constructor and Description |
---|
EmptyDiscardStateObjectForRegister(StateHandleID stateHandleID) |
IncrementalRemoteKeyedStateHandle(UUID backendIdentifier,
KeyGroupRange keyGroupRange,
long checkpointId,
List<IncrementalKeyedStateHandle.HandleAndLocalPath> sharedState,
List<IncrementalKeyedStateHandle.HandleAndLocalPath> privateState,
StreamStateHandle metaStateHandle,
long persistedSizeOfThisCheckpoint,
StateHandleID stateHandleId) |
SharedStateRegistryKey(String prefix,
StateHandleID stateHandleID) |
Modifier and Type | Method and Description |
---|---|
StateHandleID |
ChangelogStateBackendLocalHandle.getStateHandleId() |
StateHandleID |
ChangelogStateBackendHandle.ChangelogStateBackendHandleImpl.getStateHandleId() |
StateHandleID |
ChangelogStateHandleStreamImpl.getStateHandleId() |
Modifier and Type | Method and Description |
---|---|
static ChangelogStateBackendHandle.ChangelogStateBackendHandleImpl |
ChangelogStateBackendHandle.ChangelogStateBackendHandleImpl.restore(List<KeyedStateHandle> materialized,
List<ChangelogStateHandle> nonMaterialized,
KeyGroupRange keyGroupRange,
long checkpointId,
long materializationID,
long persistedSizeOfThisCheckpoint,
StateHandleID stateHandleId) |
static ChangelogStateHandleStreamImpl |
ChangelogStateHandleStreamImpl.restore(List<Tuple2<StreamStateHandle,Long>> handlesAndOffsets,
KeyGroupRange keyGroupRange,
long size,
long incrementalSize,
String storageIdentifier,
StateHandleID stateHandleID) |
Modifier and Type | Method and Description |
---|---|
StateHandleID |
InMemoryChangelogStateHandle.getStateHandleId() |
Modifier and Type | Method and Description |
---|---|
static InMemoryChangelogStateHandle |
InMemoryChangelogStateHandle.restore(List<StateChange> changes,
SequenceNumber from,
SequenceNumber to,
KeyGroupRange keyGroupRange,
StateHandleID stateHandleId) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.