Package org.apache.flink.table.runtime.typeutils

Class RawValueDataSerializer.RawValueDataSerializerSnapshot<T>

java.lang.Object

org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshot<org.apache.flink.table.data.RawValueData<T>,RawValueDataSerializer<T>>

org.apache.flink.table.runtime.typeutils.RawValueDataSerializer.RawValueDataSerializerSnapshot<T>

All Implemented Interfaces:

org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<org.apache.flink.table.data.RawValueData<T>>

Enclosing class:

RawValueDataSerializer<T>

public static final class RawValueDataSerializer.RawValueDataSerializerSnapshot<T>
extends org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshot<org.apache.flink.table.data.RawValueData<T>,RawValueDataSerializer<T>>

TypeSerializerSnapshot for RawValueDataSerializer.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshot

org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshot.OuterSchemaCompatibility

Constructor Summary

Constructors

Constructor	Description
RawValueDataSerializerSnapshot()
RawValueDataSerializerSnapshot(RawValueDataSerializer<T> serializerInstance)

Method Summary

Modifier and Type	Method	Description
protected RawValueDataSerializer<T>	createOuterSerializerWithNestedSerializers(org.apache.flink.api.common.typeutils.TypeSerializer<?>[] nestedSerializers)
protected int	getCurrentOuterSnapshotVersion()
protected org.apache.flink.api.common.typeutils.TypeSerializer<?>[]	getNestedSerializers(RawValueDataSerializer<T> outerSerializer)

Methods inherited from class org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshot

getCurrentVersion, getNestedSerializerSnapshots, isOuterSnapshotCompatible, readOuterSnapshot, readSnapshot, resolveOuterSchemaCompatibility, resolveOuterSchemaCompatibility, resolveSchemaCompatibility, restoreSerializer, writeOuterSnapshot, writeSnapshot

Methods inherited from class java.lang.Object

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

Constructor Detail

RawValueDataSerializerSnapshot

public RawValueDataSerializerSnapshot()

RawValueDataSerializerSnapshot

public RawValueDataSerializerSnapshot(RawValueDataSerializer<T> serializerInstance)

Method Detail

getCurrentOuterSnapshotVersion

protected int getCurrentOuterSnapshotVersion()

Specified by:

getCurrentOuterSnapshotVersion in class org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshot<org.apache.flink.table.data.RawValueData<T>,RawValueDataSerializer<T>>

getNestedSerializers

protected org.apache.flink.api.common.typeutils.TypeSerializer<?>[] getNestedSerializers(RawValueDataSerializer<T> outerSerializer)

Specified by:

getNestedSerializers in class org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshot<org.apache.flink.table.data.RawValueData<T>,RawValueDataSerializer<T>>

createOuterSerializerWithNestedSerializers

protected RawValueDataSerializer<T> createOuterSerializerWithNestedSerializers(org.apache.flink.api.common.typeutils.TypeSerializer<?>[] nestedSerializers)

Specified by:

createOuterSerializerWithNestedSerializers in class org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshot<org.apache.flink.table.data.RawValueData<T>,RawValueDataSerializer<T>>