Uses of Interface
org.apache.flink.util.Disposable

Packages that use Disposable

Package	Description
org.apache.flink.contrib.streaming.state
org.apache.flink.runtime.checkpoint.metadata
org.apache.flink.runtime.operators.sort
org.apache.flink.runtime.state
org.apache.flink.runtime.state.heap	This package contains the classes for key/value state backends that store the state on the JVM heap as objects.
org.apache.flink.state.changelog
org.apache.flink.state.forst
org.apache.flink.streaming.api.operators
org.apache.flink.streaming.api.operators.sorted.state

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

Classes in org.apache.flink.contrib.streaming.state that implement Disposable

Modifier and Type	Class and Description
class	RocksDBKeyedStateBackend<K> An AbstractKeyedStateBackend that stores its state in RocksDB and serializes state to streams provided by a CheckpointStreamFactory upon checkpointing.

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

Classes in org.apache.flink.runtime.checkpoint.metadata that implement Disposable

Modifier and Type	Class and Description
class	CheckpointMetadata The metadata of a snapshot (checkpoint or savepoint).

Uses of Disposable in org.apache.flink.runtime.operators.sort

Subinterfaces of Disposable in org.apache.flink.runtime.operators.sort

Modifier and Type	Interface and Description
interface	InMemorySorter<T>

Classes in org.apache.flink.runtime.operators.sort that implement Disposable

Modifier and Type	Class and Description
class	FixedLengthRecordSorter<T>
class	NormalizedKeySorter<T>

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

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

Modifier and Type	Interface and Description
interface	AsyncKeyedStateBackend An async keyed state backend provides methods supporting to access keyed state asynchronously and in batch.
interface	CheckpointableKeyedStateBackend<K> Interface that combines both, the KeyedStateBackend interface, which encapsulates methods responsible for keyed state management and the Snapshotable which tells the system how to snapshot the underlying state.
interface	KeyedStateBackend<K> A keyed state backend provides methods for managing keyed state.
interface	OperatorStateBackend Interface that combines both, the user facing OperatorStateStore interface and the system interface Snapshotable
interface	TestableKeyedStateBackend<K> A keyed state backend interface for internal testing purpose.

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

Modifier and Type	Class and Description
class	AbstractKeyedStateBackend<K> Base implementation of KeyedStateBackend.
class	DefaultOperatorStateBackend Default implementation of OperatorStateStore that provides the ability to make snapshots.

Uses of Disposable in org.apache.flink.runtime.state.heap

Classes in org.apache.flink.runtime.state.heap that implement Disposable

Modifier and Type	Class and Description
class	HeapKeyedStateBackend<K> A AbstractKeyedStateBackend that keeps state on the Java Heap and will serialize state to streams provided by a CheckpointStreamFactory upon checkpointing.

Uses of Disposable in org.apache.flink.state.changelog

Classes in org.apache.flink.state.changelog that implement Disposable

Modifier and Type	Class and Description
class	ChangelogKeyedStateBackend<K> A KeyedStateBackend that keeps state on the underlying delegated keyed state backend as well as on the state change log.

Uses of Disposable in org.apache.flink.state.forst

Classes in org.apache.flink.state.forst that implement Disposable

Modifier and Type	Class and Description
class	ForStKeyedStateBackend<K> A KeyedStateBackend that stores its state in ForSt.

Uses of Disposable in org.apache.flink.streaming.api.operators

Classes in org.apache.flink.streaming.api.operators with type parameters of type Disposable

Modifier and Type	Class and Description
class	BackendRestorerProcedure<T extends Closeable & Disposable,S extends StateObject> This class implements the logic that creates (and potentially restores) a state backend.
protected static interface	StreamTaskStateInitializerImpl.KeyedStateBackendCreator<K,R extends Disposable & Closeable> Functional interface to create the keyed state backend.

Methods in org.apache.flink.streaming.api.operators with type parameters of type Disposable

Modifier and Type

Method and Description

protected <K,R extends Disposable & Closeable> R

StreamTaskStateInitializerImpl.keyedStatedBackend(TypeSerializer<K> keySerializer, String operatorIdentifierText, PrioritizedOperatorSubtaskState prioritizedOperatorSubtaskStates, CloseableRegistry backendCloseableRegistry, MetricGroup metricGroup, double managedMemoryFraction, StateObject.StateObjectSizeStatsCollector statsCollector, StreamTaskStateInitializerImpl.KeyedStateBackendCreator<K,R> keyedStateBackendCreator)

Uses of Disposable in org.apache.flink.streaming.api.operators.sorted.state

Classes in org.apache.flink.streaming.api.operators.sorted.state that implement Disposable

Modifier and Type	Class and Description
class	BatchExecutionKeyedStateBackend<K> A CheckpointableKeyedStateBackend which keeps values for a single key at a time.