<K,OUT> org.apache.flink.api.java.operators.DataSource<OUT> |
ExistingSavepoint.readKeyedState(String uid,
KeyedStateReaderFunction<K,OUT> function) |
Deprecated.
Read keyed state from an operator in a Savepoint.
|
<K,OUT> org.apache.flink.api.java.operators.DataSource<OUT> |
ExistingSavepoint.readKeyedState(String uid,
KeyedStateReaderFunction<K,OUT> function,
org.apache.flink.api.common.typeinfo.TypeInformation<K> keyTypeInfo,
org.apache.flink.api.common.typeinfo.TypeInformation<OUT> outTypeInfo) |
Deprecated.
Read keyed state from an operator in a Savepoint.
|
<K,OUT> org.apache.flink.streaming.api.datastream.DataStream<OUT> |
SavepointReader.readKeyedState(String uid,
KeyedStateReaderFunction<K,OUT> function) |
Deprecated.
|
<K,OUT> org.apache.flink.streaming.api.datastream.DataStream<OUT> |
SavepointReader.readKeyedState(String uid,
KeyedStateReaderFunction<K,OUT> function,
org.apache.flink.api.common.typeinfo.TypeInformation<K> keyTypeInfo,
org.apache.flink.api.common.typeinfo.TypeInformation<OUT> outTypeInfo) |
Deprecated.
|
<K,OUT> org.apache.flink.streaming.api.datastream.DataStream<OUT> |
SavepointReader.readKeyedState(OperatorIdentifier identifier,
KeyedStateReaderFunction<K,OUT> function) |
Read keyed state from an operator in a Savepoint.
|
<K,OUT> org.apache.flink.streaming.api.datastream.DataStream<OUT> |
SavepointReader.readKeyedState(OperatorIdentifier identifier,
KeyedStateReaderFunction<K,OUT> function,
org.apache.flink.api.common.typeinfo.TypeInformation<K> keyTypeInfo,
org.apache.flink.api.common.typeinfo.TypeInformation<OUT> outTypeInfo) |
Read keyed state from an operator in a Savepoint.
|