Uses of Class
org.apache.flink.runtime.state.KeyGroupStatePartitionStreamProvider
-
Packages that use KeyGroupStatePartitionStreamProvider Package Description org.apache.flink.runtime.state -
-
Uses of KeyGroupStatePartitionStreamProvider in org.apache.flink.runtime.state
Methods in org.apache.flink.runtime.state that return types with arguments of type KeyGroupStatePartitionStreamProvider Modifier and Type Method Description Iterable<KeyGroupStatePartitionStreamProvider>StateInitializationContext. getRawKeyedStateInputs()Returns an iterable to obtain input streams for previously stored keyed state partitions that are assigned to this operator.Iterable<KeyGroupStatePartitionStreamProvider>StateInitializationContextImpl. getRawKeyedStateInputs()Constructor parameters in org.apache.flink.runtime.state with type arguments of type KeyGroupStatePartitionStreamProvider Constructor Description StateInitializationContextImpl(Long restoredCheckpointId, org.apache.flink.api.common.state.OperatorStateStore operatorStateStore, org.apache.flink.api.common.state.KeyedStateStore keyedStateStore, Iterable<KeyGroupStatePartitionStreamProvider> rawKeyedStateInputs, Iterable<StatePartitionStreamProvider> rawOperatorStateInputs)
-