Uses of Interface
org.apache.flink.runtime.state.StreamStateHandle

Packages that use StreamStateHandle

Package	Description
org.apache.flink.changelog.fs
org.apache.flink.contrib.streaming.state
org.apache.flink.runtime.checkpoint
org.apache.flink.runtime.checkpoint.metadata
org.apache.flink.runtime.state
org.apache.flink.runtime.state.changelog
org.apache.flink.runtime.state.filesystem
org.apache.flink.runtime.state.memory

Uses of StreamStateHandle in org.apache.flink.changelog.fs

Methods in org.apache.flink.changelog.fs with parameters of type StreamStateHandle

Modifier and Type	Method and Description
CloseableIterator<StateChange>	StateChangeFormat.read(StreamStateHandle handle, long offset)

Uses of StreamStateHandle in org.apache.flink.contrib.streaming.state

Methods in org.apache.flink.contrib.streaming.state that return types with arguments of type StreamStateHandle

Modifier and Type	Method and Description
Map<StateHandleID,StreamStateHandle>	RocksDBStateUploader.uploadFilesToCheckpointFs(Map<StateHandleID,Path> files, CheckpointStreamFactory checkpointStreamFactory, CloseableRegistry closeableRegistry) Upload all the files to checkpoint fileSystem using specified number of threads.

Uses of StreamStateHandle in org.apache.flink.runtime.checkpoint

Methods in org.apache.flink.runtime.checkpoint that return StreamStateHandle

Modifier and Type	Method and Description
StreamStateHandle	CompletedCheckpoint.getMetadataHandle()

Uses of StreamStateHandle in org.apache.flink.runtime.checkpoint.metadata

Methods in org.apache.flink.runtime.checkpoint.metadata that return StreamStateHandle

Modifier and Type	Method and Description
static StreamStateHandle	MetadataV3Serializer.deserializeStreamStateHandle(DataInputStream dis)

Methods in org.apache.flink.runtime.checkpoint.metadata with parameters of type StreamStateHandle

Modifier and Type	Method and Description
static void	MetadataV3Serializer.serializeStreamStateHandle(StreamStateHandle stateHandle, DataOutputStream dos)

Uses of StreamStateHandle in org.apache.flink.runtime.state

Classes in org.apache.flink.runtime.state with type parameters of type StreamStateHandle

Modifier and Type	Class and Description
class	NonClosingCheckpointOutputStream<T extends StreamStateHandle> Abstract class to implement custom checkpoint output streams which should not be closable for user code.

Subinterfaces of StreamStateHandle in org.apache.flink.runtime.state

Modifier and Type	Interface and Description
interface	OperatorStateHandle Interface of a state handle for operator state.

Classes in org.apache.flink.runtime.state that implement StreamStateHandle

Modifier and Type	Class and Description
class	KeyGroupsSavepointStateHandle A KeyGroupsStateHandle that describes a savepoint in the unified format.
class	KeyGroupsStateHandle A handle to the partitioned stream operator state after it has been checkpointed.
class	OperatorStreamStateHandle State handle for partitionable operator state.
class	PlaceholderStreamStateHandle A placeholder state handle for shared state that will replaced by an original that was created in a previous checkpoint.
class	RetrievableStreamStateHandle<T extends Serializable> Wrapper around a StreamStateHandle to make the referenced state object retrievable trough a simple get call.

Methods in org.apache.flink.runtime.state that return StreamStateHandle

Modifier and Type	Method and Description
StreamStateHandle	DuplicatingCheckpointOutputStream.closeAndGetHandle()
abstract StreamStateHandle	CheckpointStreamFactory.CheckpointStateOutputStream.closeAndGetHandle() Closes the stream and gets a state handle that can create an input stream producing the data written to this stream.
StreamStateHandle	DuplicatingCheckpointOutputStream.closeAndGetPrimaryHandle() Returns the state handle from the DuplicatingCheckpointOutputStream.primaryOutputStream.
StreamStateHandle	DuplicatingCheckpointOutputStream.closeAndGetSecondaryHandle() Returns the state handle from the DuplicatingCheckpointOutputStream.secondaryOutputStream.
StreamStateHandle	AbstractChannelStateHandle.getDelegate()
StreamStateHandle	OperatorStreamStateHandle.getDelegateStateHandle()
StreamStateHandle	OperatorStateHandle.getDelegateStateHandle() Returns the underlying stream state handle that points to the state data.
StreamStateHandle	KeyGroupsStateHandle.getDelegateStateHandle()
StreamStateHandle	CompletedCheckpointStorageLocation.getMetadataHandle() Gets the state handle to the checkpoint's metadata.
StreamStateHandle	IncrementalLocalKeyedStateHandle.getMetaDataState()
StreamStateHandle	IncrementalRemoteKeyedStateHandle.getMetaStateHandle()
StreamStateHandle	SharedStateRegistry.Result.getReference()

Methods in org.apache.flink.runtime.state that return types with arguments of type StreamStateHandle

Modifier and Type	Method and Description
SnapshotResult<StreamStateHandle>	CheckpointStreamWithResultProvider.closeAndFinalizeCheckpointStreamResult() Closes the stream ans returns a snapshot result with the stream handle(s).
SnapshotResult<StreamStateHandle>	CheckpointStreamWithResultProvider.PrimaryStreamOnly.closeAndFinalizeCheckpointStreamResult()
SnapshotResult<StreamStateHandle>	CheckpointStreamWithResultProvider.PrimaryAndSecondaryStream.closeAndFinalizeCheckpointStreamResult()
static Set<StreamStateHandle>	AbstractChannelStateHandle.collectUniqueDelegates(Collection<? extends AbstractChannelStateHandle<?>>... collections)
Map<StateHandleID,StreamStateHandle>	IncrementalRemoteKeyedStateHandle.getPrivateState()
Map<StateHandleID,StreamStateHandle>	IncrementalRemoteKeyedStateHandle.getSharedState()

Methods in org.apache.flink.runtime.state with parameters of type StreamStateHandle

Modifier and Type	Method and Description
KeyedStateHandle	CheckpointStreamWithResultProvider.KeyedStateHandleFactory.create(KeyGroupRangeOffsets keyGroupRangeOffsets, StreamStateHandle streamStateHandle)
SharedStateRegistry.Result	SharedStateRegistry.registerReference(SharedStateRegistryKey registrationKey, StreamStateHandle state) Register a reference to the given shared state in the registry.

Method parameters in org.apache.flink.runtime.state with type arguments of type StreamStateHandle

Modifier and Type

Method and Description

static SnapshotResult<KeyedStateHandle>

CheckpointStreamWithResultProvider.toKeyedStateHandleSnapshotResult(SnapshotResult<StreamStateHandle> snapshotResult, KeyGroupRangeOffsets keyGroupRangeOffsets, CheckpointStreamWithResultProvider.KeyedStateHandleFactory stateHandleFactory) Helper method that takes a SnapshotResult and a KeyGroupRangeOffsets and creates a SnapshotResult by combining the key groups offsets with all the present stream state handles.

Constructors in org.apache.flink.runtime.state with parameters of type StreamStateHandle

Constructor and Description
IncrementalLocalKeyedStateHandle(UUID backendIdentifier, long checkpointId, DirectoryStateHandle directoryStateHandle, KeyGroupRange keyGroupRange, StreamStateHandle metaDataState, Set<StateHandleID> sharedStateHandleIDs)
IncrementalRemoteKeyedStateHandle(UUID backendIdentifier, KeyGroupRange keyGroupRange, long checkpointId, Map<StateHandleID,StreamStateHandle> sharedState, Map<StateHandleID,StreamStateHandle> privateState, StreamStateHandle metaStateHandle)
InputChannelStateHandle(InputChannelInfo info, StreamStateHandle delegate, List<Long> offset)
InputChannelStateHandle(int subtaskIndex, InputChannelInfo info, StreamStateHandle delegate, AbstractChannelStateHandle.StateContentMetaInfo contentMetaInfo)
InputChannelStateHandle(int subtaskIndex, InputChannelInfo info, StreamStateHandle delegate, List<Long> offset, long size)
KeyGroupsSavepointStateHandle(KeyGroupRangeOffsets groupRangeOffsets, StreamStateHandle streamStateHandle)
KeyGroupsStateHandle(KeyGroupRangeOffsets groupRangeOffsets, StreamStateHandle streamStateHandle)
OperatorStreamStateHandle(Map<String,OperatorStateHandle.StateMetaInfo> stateNameToPartitionOffsets, StreamStateHandle delegateStateHandle)
Result(StreamStateHandle reference, int referenceCount)
ResultSubpartitionStateHandle(int subtaskIndex, ResultSubpartitionInfo info, StreamStateHandle delegate, AbstractChannelStateHandle.StateContentMetaInfo contentMetaInfo)
ResultSubpartitionStateHandle(int subtaskIndex, ResultSubpartitionInfo info, StreamStateHandle delegate, List<Long> offset, long size)
ResultSubpartitionStateHandle(ResultSubpartitionInfo info, StreamStateHandle delegate, List<Long> offset)
RetrievableStreamStateHandle(StreamStateHandle streamStateHandle)

Constructor parameters in org.apache.flink.runtime.state with type arguments of type StreamStateHandle

Constructor and Description
IncrementalRemoteKeyedStateHandle(UUID backendIdentifier, KeyGroupRange keyGroupRange, long checkpointId, Map<StateHandleID,StreamStateHandle> sharedState, Map<StateHandleID,StreamStateHandle> privateState, StreamStateHandle metaStateHandle)
IncrementalRemoteKeyedStateHandle(UUID backendIdentifier, KeyGroupRange keyGroupRange, long checkpointId, Map<StateHandleID,StreamStateHandle> sharedState, Map<StateHandleID,StreamStateHandle> privateState, StreamStateHandle metaStateHandle)

Uses of StreamStateHandle in org.apache.flink.runtime.state.changelog

Methods in org.apache.flink.runtime.state.changelog that return types with arguments of type StreamStateHandle

Modifier and Type	Method and Description
List<Tuple2<StreamStateHandle,Long>>	ChangelogStateHandleStreamImpl.getHandlesAndOffsets()

Methods in org.apache.flink.runtime.state.changelog with parameters of type StreamStateHandle

Modifier and Type	Method and Description
CloseableIterator<StateChange>	StateChangelogHandleStreamHandleReader.StateChangeIterator.read(StreamStateHandle handle, long offset)

Constructor parameters in org.apache.flink.runtime.state.changelog with type arguments of type StreamStateHandle

Constructor and Description
ChangelogStateHandleStreamImpl(List<Tuple2<StreamStateHandle,Long>> handlesAndOffsets, KeyGroupRange keyGroupRange, long size)

Uses of StreamStateHandle in org.apache.flink.runtime.state.filesystem

Classes in org.apache.flink.runtime.state.filesystem that implement StreamStateHandle

Modifier and Type	Class and Description
class	FileStateHandle StreamStateHandle for state that was written to a file stream.
class	RelativeFileStateHandle A StreamStateHandle for state that was written to a file stream.

Methods in org.apache.flink.runtime.state.filesystem that return StreamStateHandle

Modifier and Type	Method and Description
StreamStateHandle	FsCheckpointStreamFactory.FsCheckpointStateOutputStream.closeAndGetHandle()

Uses of StreamStateHandle in org.apache.flink.runtime.state.memory

Classes in org.apache.flink.runtime.state.memory that implement StreamStateHandle

Modifier and Type	Class and Description
class	ByteStreamStateHandle A state handle that contains stream state in a byte array.

Methods in org.apache.flink.runtime.state.memory that return StreamStateHandle

Modifier and Type	Method and Description
StreamStateHandle	MemCheckpointStreamFactory.MemoryCheckpointOutputStream.closeAndGetHandle()