Package org.apache.beam.runners.flink.translation.types

Class UnversionedTypeSerializerSnapshot<T>

java.lang.Object

org.apache.beam.runners.flink.translation.types.UnversionedTypeSerializerSnapshot<T>

All Implemented Interfaces:

org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<T>

public class UnversionedTypeSerializerSnapshot<T>
extends Object
implements org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<T>

A legacy snapshot which does not care about schema compatibility.

Constructor Summary

Constructors

Constructor	Description
UnversionedTypeSerializerSnapshot()	Needs to be public to work with VersionedIOReadableWritable.
UnversionedTypeSerializerSnapshot(CoderTypeSerializer<T> serializer)

Method Summary

Modifier and Type	Method	Description
int	getCurrentVersion()
void	readSnapshot(int version, org.apache.flink.core.memory.DataInputView dataInputView, ClassLoader classLoader)
org.apache.flink.api.common.typeutils.TypeSerializerSchemaCompatibility<T>	resolveSchemaCompatibility(org.apache.flink.api.common.typeutils.TypeSerializer<T> newSerializer)
org.apache.flink.api.common.typeutils.TypeSerializer<T>	restoreSerializer()
void	writeSnapshot(org.apache.flink.core.memory.DataOutputView dataOutputView)

Methods inherited from class java.lang.Object

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

Constructor Details

UnversionedTypeSerializerSnapshot

public UnversionedTypeSerializerSnapshot()

Needs to be public to work with VersionedIOReadableWritable.

UnversionedTypeSerializerSnapshot

public UnversionedTypeSerializerSnapshot(CoderTypeSerializer<T> serializer)

Method Details

getCurrentVersion

public int getCurrentVersion()

Specified by:

getCurrentVersion in interface org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<T>

writeSnapshot

public void writeSnapshot(org.apache.flink.core.memory.DataOutputView dataOutputView)
                   throws IOException

Specified by:

writeSnapshot in interface org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<T>

Throws:

IOException

readSnapshot

public void readSnapshot(int version,
 org.apache.flink.core.memory.DataInputView dataInputView,
 ClassLoader classLoader)
                  throws IOException

Specified by:

readSnapshot in interface org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<T>

Throws:

IOException

restoreSerializer

public org.apache.flink.api.common.typeutils.TypeSerializer<T> restoreSerializer()

Specified by:

restoreSerializer in interface org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<T>

resolveSchemaCompatibility

public org.apache.flink.api.common.typeutils.TypeSerializerSchemaCompatibility<T> resolveSchemaCompatibility(org.apache.flink.api.common.typeutils.TypeSerializer<T> newSerializer)

Specified by:

resolveSchemaCompatibility in interface org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<T>