public interface OperatorStateHandle extends StreamStateHandle
Modifier and Type | Interface and Description |
---|---|
static class |
OperatorStateHandle.Mode
The modes that determine how an
OperatorStreamStateHandle is assigned to tasks during
restore. |
static class |
OperatorStateHandle.StateMetaInfo
Meta information about the operator state handle.
|
Modifier and Type | Method and Description |
---|---|
StreamStateHandle |
getDelegateStateHandle()
Returns the underlying stream state handle that points to the state data.
|
Map<String,OperatorStateHandle.StateMetaInfo> |
getStateNameToPartitionOffsets()
Returns a map of meta data for all contained states by their name.
|
FSDataInputStream |
openInputStream()
Returns an input stream to read the operator state information.
|
asBytesIfInMemory, getStreamStateHandleID
discardState, getStateSize
Map<String,OperatorStateHandle.StateMetaInfo> getStateNameToPartitionOffsets()
FSDataInputStream openInputStream() throws IOException
openInputStream
in interface StreamStateHandle
IOException
StreamStateHandle getDelegateStateHandle()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.