Package | Description |
---|---|
org.apache.flink.state.api | |
org.apache.flink.state.api.input.operator |
Modifier and Type | Method and Description |
---|---|
<K,OUT> DataSource<OUT> |
ExistingSavepoint.readKeyedState(String uid,
KeyedStateReaderFunction<K,OUT> function)
Deprecated.
Read keyed state from an operator in a
Savepoint . |
<K,OUT> DataStream<OUT> |
SavepointReader.readKeyedState(String uid,
KeyedStateReaderFunction<K,OUT> function)
Read keyed state from an operator in a
Savepoint . |
<K,OUT> DataSource<OUT> |
ExistingSavepoint.readKeyedState(String uid,
KeyedStateReaderFunction<K,OUT> function,
TypeInformation<K> keyTypeInfo,
TypeInformation<OUT> outTypeInfo)
Deprecated.
Read keyed state from an operator in a
Savepoint . |
<K,OUT> DataStream<OUT> |
SavepointReader.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 |
---|
KeyedStateReaderOperator(KeyedStateReaderFunction<KEY,OUT> function,
TypeInformation<KEY> keyType) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.