Package | Description |
---|---|
org.apache.flink.runtime.state |
Modifier and Type | Method and Description |
---|---|
SharedStateRegistryKey |
IncrementalRemoteKeyedStateHandle.createSharedStateRegistryKeyFromFileName(StateHandleID shId)
Create a unique key to register one of our shared state handles.
|
Modifier and Type | Method and Description |
---|---|
StreamStateHandle |
SharedStateRegistry.registerReference(SharedStateRegistryKey registrationKey,
StreamStateHandle state,
long checkpointID)
Register a reference to the given shared state in the registry.
|
StreamStateHandle |
SharedStateRegistryImpl.registerReference(SharedStateRegistryKey registrationKey,
StreamStateHandle state,
long checkpointID) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.