Package | Description |
---|---|
org.apache.flink.runtime.state | |
org.apache.flink.runtime.state.filesystem | |
org.apache.flink.runtime.state.memory |
Modifier and Type | Method and Description |
---|---|
PhysicalStateHandleID |
StreamStateHandle.getStreamStateHandleID() |
PhysicalStateHandleID |
SharedStateRegistryImpl.EmptyDiscardStateObjectForRegister.getStreamStateHandleID() |
PhysicalStateHandleID |
PlaceholderStreamStateHandle.getStreamStateHandleID() |
PhysicalStateHandleID |
KeyGroupsStateHandle.getStreamStateHandleID() |
PhysicalStateHandleID |
RetrievableStreamStateHandle.getStreamStateHandleID() |
PhysicalStateHandleID |
OperatorStreamStateHandle.getStreamStateHandleID() |
Constructor and Description |
---|
PlaceholderStreamStateHandle(PhysicalStateHandleID physicalID,
long stateSize) |
Modifier and Type | Method and Description |
---|---|
PhysicalStateHandleID |
FileStateHandle.getStreamStateHandleID() |
Modifier and Type | Method and Description |
---|---|
PhysicalStateHandleID |
ByteStreamStateHandle.getStreamStateHandleID() |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.