Package | Description |
---|---|
org.apache.flink.state.api | |
org.apache.flink.state.api.runtime.metadata |
Modifier and Type | Method and Description |
---|---|
static OperatorIdentifier |
OperatorIdentifier.forUid(String uid) |
static OperatorIdentifier |
OperatorIdentifier.forUidHash(String uidHash) |
Modifier and Type | Method and Description |
---|---|
SavepointWriter |
SavepointWriter.changeOperatorIdentifier(OperatorIdentifier from,
OperatorIdentifier to)
Changes the identifier of an operator.
|
<K,V> DataStream<Tuple2<K,V>> |
SavepointReader.readBroadcastState(OperatorIdentifier identifier,
String name,
TypeInformation<K> keyTypeInfo,
TypeInformation<V> valueTypeInfo)
Read operator
BroadcastState from a Savepoint . |
<K,V> DataStream<Tuple2<K,V>> |
SavepointReader.readBroadcastState(OperatorIdentifier identifier,
String name,
TypeInformation<K> keyTypeInfo,
TypeInformation<V> valueTypeInfo,
TypeSerializer<K> keySerializer,
TypeSerializer<V> valueSerializer)
Read operator
BroadcastState from a Savepoint when a custom serializer was
used; e.g., a different serializer than the one returned by TypeInformation#createSerializer . |
<K,OUT> DataStream<OUT> |
SavepointReader.readKeyedState(OperatorIdentifier identifier,
KeyedStateReaderFunction<K,OUT> function)
Read keyed state from an operator in a
Savepoint . |
<K,OUT> DataStream<OUT> |
SavepointReader.readKeyedState(OperatorIdentifier identifier,
KeyedStateReaderFunction<K,OUT> function,
TypeInformation<K> keyTypeInfo,
TypeInformation<OUT> outTypeInfo)
Read keyed state from an operator in a
Savepoint . |
<T> DataStream<T> |
SavepointReader.readListState(OperatorIdentifier identifier,
String name,
TypeInformation<T> typeInfo)
Read operator
ListState from a Savepoint . |
<T> DataStream<T> |
SavepointReader.readListState(OperatorIdentifier identifier,
String name,
TypeInformation<T> typeInfo,
TypeSerializer<T> serializer)
Read operator
ListState from a Savepoint when a custom serializer was used;
e.g., a different serializer than the one returned by TypeInformation#createSerializer . |
<T> DataStream<T> |
SavepointReader.readUnionState(OperatorIdentifier identifier,
String name,
TypeInformation<T> typeInfo)
Read operator
UnionState from a Savepoint . |
<T> DataStream<T> |
SavepointReader.readUnionState(OperatorIdentifier identifier,
String name,
TypeInformation<T> typeInfo,
TypeSerializer<T> serializer)
Read operator
UnionState from a Savepoint when a custom serializer was used;
e.g., a different serializer than the one returned by TypeInformation#createSerializer . |
SavepointWriter |
SavepointWriter.removeOperator(OperatorIdentifier identifier)
Drop an existing operator from the savepoint.
|
<T> SavepointWriter |
SavepointWriter.withOperator(OperatorIdentifier identifier,
StateBootstrapTransformation<T> transformation)
Adds a new operator to the savepoint.
|
Modifier and Type | Method and Description |
---|---|
void |
SavepointMetadataV2.addOperator(OperatorIdentifier identifier,
StateBootstrapTransformation<?> transformation) |
OperatorState |
SavepointMetadataV2.getOperatorState(OperatorIdentifier identifier) |
void |
SavepointMetadataV2.removeOperator(OperatorIdentifier identifier) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.