org.apache.flink.runtime.state

Interface StreamStateHandle

All Superinterfaces:

Serializable, StateObject

All Known Subinterfaces:

OperatorStateHandle

All Known Implementing Classes:

ByteStreamStateHandle, FileStateHandle, KeyGroupsSavepointStateHandle, KeyGroupsStateHandle, OperatorStreamStateHandle, PlaceholderStreamStateHandle, RelativeFileStateHandle, RetrievableStreamStateHandle

public interface StreamStateHandle
extends StateObject

A StateObject that represents state that was written to a stream. The data can be read back via openInputStream().

Method Summary

Modifier and Type	Method and Description
Optional<byte[]>	asBytesIfInMemory()
FSDataInputStream	openInputStream() Returns an FSDataInputStream that can be used to read back the data that was previously written to the stream.

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

discardState, getStateSize

Method Detail

openInputStream

FSDataInputStream openInputStream()
                           throws IOException

Returns an FSDataInputStream that can be used to read back the data that was previously written to the stream.

Throws:

IOException

asBytesIfInMemory

Optional<byte[]> asBytesIfInMemory()

Returns:

Content of this handle as bytes array if it is already in memory.