org.apache.flink.runtime.state

Interface OperatorStateHandle

All Superinterfaces:

Serializable, StateObject, StreamStateHandle

All Known Implementing Classes:

OperatorStreamStateHandle

public interface OperatorStateHandle
extends StreamStateHandle

Interface of a state handle for operator state.

Nested Class Summary

Nested Classes

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.

Method Summary

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.

Methods inherited from interface org.apache.flink.runtime.state.StateObject

discardState, getStateSize

Method Detail

getStateNameToPartitionOffsets

Map<String,OperatorStateHandle.StateMetaInfo> getStateNameToPartitionOffsets()

Returns a map of meta data for all contained states by their name.

openInputStream

FSDataInputStream openInputStream()
                           throws IOException

Returns an input stream to read the operator state information.

Specified by:

openInputStream in interface StreamStateHandle

Throws:

IOException

getDelegateStateHandle

StreamStateHandle getDelegateStateHandle()

Returns the underlying stream state handle that points to the state data.