Package org.apache.flink.runtime.state
Interface StateSnapshotTransformer.StateSnapshotTransformFactory<T>
-
- All Known Implementing Classes:
StateSnapshotTransformers.ListStateSnapshotTransformFactory,StateSnapshotTransformers.MapStateSnapshotTransformFactory,StateSnapshotTransformers.StateSnapshotTransformFactoryWrapAdaptor
- Enclosing interface:
- StateSnapshotTransformer<T>
public static interface StateSnapshotTransformer.StateSnapshotTransformFactory<T>This factory creates state transformers depending on the form of values to transform.If there is no transforming needed, the factory methods return
Optional.empty().
-
-
Field Summary
Fields Modifier and Type Field Description static StateSnapshotTransformer.StateSnapshotTransformFactory<?>NO_TRANSFORM
-
Method Summary
All Methods Static Methods Instance Methods Abstract Methods Modifier and Type Method Description Optional<StateSnapshotTransformer<T>>createForDeserializedState()Optional<StateSnapshotTransformer<byte[]>>createForSerializedState()static <T> StateSnapshotTransformer.StateSnapshotTransformFactory<T>createNoTransform()static <T> StateSnapshotTransformer.StateSnapshotTransformFactory<T>noTransform()
-
-
-
Field Detail
-
NO_TRANSFORM
static final StateSnapshotTransformer.StateSnapshotTransformFactory<?> NO_TRANSFORM
-
-
Method Detail
-
noTransform
static <T> StateSnapshotTransformer.StateSnapshotTransformFactory<T> noTransform()
-
createNoTransform
static <T> StateSnapshotTransformer.StateSnapshotTransformFactory<T> createNoTransform()
-
createForDeserializedState
Optional<StateSnapshotTransformer<T>> createForDeserializedState()
-
createForSerializedState
Optional<StateSnapshotTransformer<byte[]>> createForSerializedState()
-
-