SavepointWriter |
SavepointWriter.changeOperatorIdentifier(OperatorIdentifier from,
OperatorIdentifier to) |
Changes the identifier of an operator.
|
<K,V>
org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.api.java.tuple.Tuple2<K,V>> |
SavepointReader.readBroadcastState(OperatorIdentifier identifier,
String name,
org.apache.flink.api.common.typeinfo.TypeInformation<K> keyTypeInfo,
org.apache.flink.api.common.typeinfo.TypeInformation<V> valueTypeInfo) |
Read operator BroadcastState from a Savepoint.
|
<K,V>
org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.api.java.tuple.Tuple2<K,V>> |
SavepointReader.readBroadcastState(OperatorIdentifier identifier,
String name,
org.apache.flink.api.common.typeinfo.TypeInformation<K> keyTypeInfo,
org.apache.flink.api.common.typeinfo.TypeInformation<V> valueTypeInfo,
org.apache.flink.api.common.typeutils.TypeSerializer<K> keySerializer,
org.apache.flink.api.common.typeutils.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>
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.
|
<T> org.apache.flink.streaming.api.datastream.DataStream<T> |
SavepointReader.readListState(OperatorIdentifier identifier,
String name,
org.apache.flink.api.common.typeinfo.TypeInformation<T> typeInfo) |
Read operator ListState from a Savepoint.
|
<T> org.apache.flink.streaming.api.datastream.DataStream<T> |
SavepointReader.readListState(OperatorIdentifier identifier,
String name,
org.apache.flink.api.common.typeinfo.TypeInformation<T> typeInfo,
org.apache.flink.api.common.typeutils.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> org.apache.flink.streaming.api.datastream.DataStream<T> |
SavepointReader.readUnionState(OperatorIdentifier identifier,
String name,
org.apache.flink.api.common.typeinfo.TypeInformation<T> typeInfo) |
Read operator UnionState from a Savepoint.
|
<T> org.apache.flink.streaming.api.datastream.DataStream<T> |
SavepointReader.readUnionState(OperatorIdentifier identifier,
String name,
org.apache.flink.api.common.typeinfo.TypeInformation<T> typeInfo,
org.apache.flink.api.common.typeutils.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.
|