org.apache.flink.api.common.typeutils

Class TypeSerializerUtils

java.lang.Object

org.apache.flink.api.common.typeutils.TypeSerializerUtils

public final class TypeSerializerUtils
extends Object

Utilities for dealing with the TypeSerializer and the TypeSerializerSnapshot.

Method Summary

Modifier and Type	Method and Description
static TypeSerializerSnapshot<?>[]	snapshotBackwardsCompatible(TypeSerializer<?>... originatingSerializers) Takes snapshots of the given serializers.
static <T> TypeSerializerSnapshot<T>	snapshotBackwardsCompatible(TypeSerializer<T> originatingSerializer) Takes a snapshot of the given serializer.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

snapshotBackwardsCompatible

public static TypeSerializerSnapshot<?>[] snapshotBackwardsCompatible(TypeSerializer<?>... originatingSerializers)

Takes snapshots of the given serializers. In case where the snapshots are still extending the old TypeSerializerConfigSnapshot class, the snapshots are set up properly (with their originating serializer) such that the backwards compatible code paths work.

snapshotBackwardsCompatible

public static <T> TypeSerializerSnapshot<T> snapshotBackwardsCompatible(TypeSerializer<T> originatingSerializer)

Takes a snapshot of the given serializer. In case where the snapshot is still extending the old TypeSerializerConfigSnapshot class, the snapshot is set up properly (with its originating serializer) such that the backwards compatible code paths work.