org.apache.flink.api.common.typeutils

Class TypeSerializerSnapshotSerializationUtil

java.lang.Object

org.apache.flink.api.common.typeutils.TypeSerializerSnapshotSerializationUtil

public class TypeSerializerSnapshotSerializationUtil
extends Object

Utility methods for serialization of TypeSerializerSnapshot.

Constructor Summary

Constructors

Constructor and Description
TypeSerializerSnapshotSerializationUtil()

Method Summary

Modifier and Type	Method and Description
static <T> TypeSerializerSnapshot<T>	readAndInstantiateSnapshotClass(DataInputView in, ClassLoader cl)
static <T> TypeSerializerSnapshot<T>	readSerializerSnapshot(DataInputView in, ClassLoader userCodeClassLoader) Reads from a data input view a TypeSerializerSnapshot that was previously written using #writeSerializerSnapshot(DataOutputView, TypeSerializerSnapshot.
static <T> void	writeSerializerSnapshot(DataOutputView out, TypeSerializerSnapshot<T> serializerSnapshot) Writes a TypeSerializerSnapshot to the provided data output view.

Methods inherited from class java.lang.Object

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

Constructor Detail

TypeSerializerSnapshotSerializationUtil

public TypeSerializerSnapshotSerializationUtil()

Method Detail

writeSerializerSnapshot

public static <T> void writeSerializerSnapshot(DataOutputView out,
                                               TypeSerializerSnapshot<T> serializerSnapshot)
                                        throws IOException

Writes a TypeSerializerSnapshot to the provided data output view.

It is written with a format that can be later read again using readSerializerSnapshot(DataInputView, ClassLoader).

Parameters:

out - the data output view

serializerSnapshot - the serializer configuration snapshot to write

Throws:

IOException

readSerializerSnapshot

public static <T> TypeSerializerSnapshot<T> readSerializerSnapshot(DataInputView in,
                                                                   ClassLoader userCodeClassLoader)
                                                            throws IOException

Reads from a data input view a TypeSerializerSnapshot that was previously written using #writeSerializerSnapshot(DataOutputView, TypeSerializerSnapshot.

Parameters:

in - the data input view

userCodeClassLoader - the user code class loader to use

Returns:

the read serializer configuration snapshot

Throws:

IOException

readAndInstantiateSnapshotClass

public static <T> TypeSerializerSnapshot<T> readAndInstantiateSnapshotClass(DataInputView in,
                                                                            ClassLoader cl)
                                                                     throws IOException

Throws:

IOException