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 and Description
static StateSnapshotTransformer.StateSnapshotTransformFactory<?>	NO_TRANSFORM

Method Summary

Modifier and Type	Method and 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()