Package | Description |
---|---|
org.apache.flink.state.api | |
org.apache.flink.state.api.input |
Modifier and Type | Method and Description |
---|---|
<K,OUT> DataSet<OUT> |
ExistingSavepoint.readKeyedState(String uid,
KeyedStateReaderFunction<K,OUT> function) |
<K,OUT> DataSet<OUT> |
ExistingSavepoint.readKeyedState(String uid,
KeyedStateReaderFunction<K,OUT> function,
TypeInformation<K> keyTypeInfo,
TypeInformation<OUT> outTypeInfo)
Read keyed state from an operator in a
Savepoint . |
Constructor and Description |
---|
KeyedStateInputFormat(OperatorState operatorState,
StateBackend stateBackend,
TypeInformation<K> keyType,
KeyedStateReaderFunction<K,OUT> userFunction)
Creates an input format for reading partitioned state from an operator in a savepoint.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.