Package | Description |
---|---|
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.
|
Modifier and Type | Method and Description |
---|---|
Iterable<StatePartitionStreamProvider> |
StateInitializationContextImpl.getRawOperatorStateInputs() |
Iterable<StatePartitionStreamProvider> |
StateInitializationContext.getRawOperatorStateInputs()
Returns an iterable to obtain input streams for previously stored operator state partitions that are assigned to
this operator.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.