Uses of Class
org.apache.flink.runtime.state.StatePartitionStreamProvider

Packages that use StatePartitionStreamProvider

Package	Description
org.apache.flink.runtime.state
org.apache.flink.streaming.api.operators

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

Subclasses of StatePartitionStreamProvider in org.apache.flink.runtime.state

Modifier and Type	Class and Description
class	KeyGroupStatePartitionStreamProvider This class provides access to an input stream that contains state data for one key group and the key group id.

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

Modifier and Type	Method and Description
Iterable<StatePartitionStreamProvider>	StateInitializationContext.getRawOperatorStateInputs() Returns an iterable to obtain input streams for previously stored operator state partitions that are assigned to this operator.
Iterable<StatePartitionStreamProvider>	StateInitializationContextImpl.getRawOperatorStateInputs()

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

Constructor and Description
StateInitializationContextImpl(Long restoredCheckpointId, OperatorStateStore operatorStateStore, KeyedStateStore keyedStateStore, Iterable<KeyGroupStatePartitionStreamProvider> rawKeyedStateInputs, Iterable<StatePartitionStreamProvider> rawOperatorStateInputs)

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

Methods in org.apache.flink.streaming.api.operators that return types with arguments of type StatePartitionStreamProvider

Modifier and Type	Method and Description
CloseableIterable<StatePartitionStreamProvider>	StreamOperatorStateContext.rawOperatorStateInputs() Returns an iterable to obtain input streams for previously stored operator state partitions that are assigned to this stream operator.
protected CloseableIterable<StatePartitionStreamProvider>	StreamTaskStateInitializerImpl.rawOperatorStateInputs(Iterator<StateObjectCollection<OperatorStateHandle>> restoreStateAlternatives, StateObject.StateObjectSizeStatsCollector statsCollector)