Package org.apache.flink.table.runtime.sequencedmultisetstate.linked

Class RowSqnInfoSerializer.RowSqnInfoSerializerSnapshot

java.lang.Object

org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshot<org.apache.flink.table.runtime.sequencedmultisetstate.linked.RowSqnInfo,RowSqnInfoSerializer>

org.apache.flink.table.runtime.sequencedmultisetstate.linked.RowSqnInfoSerializer.RowSqnInfoSerializerSnapshot

All Implemented Interfaces:

org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<org.apache.flink.table.runtime.sequencedmultisetstate.linked.RowSqnInfo>

Enclosing class:

RowSqnInfoSerializer

public static class RowSqnInfoSerializer.RowSqnInfoSerializerSnapshot
extends org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshot<org.apache.flink.table.runtime.sequencedmultisetstate.linked.RowSqnInfo,RowSqnInfoSerializer>

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
RowSqnInfoSerializerSnapshot()

Method Summary

Modifier and Type	Method	Description
protected RowSqnInfoSerializer	createOuterSerializerWithNestedSerializers(org.apache.flink.api.common.typeutils.TypeSerializer<?>[] nestedSerializers)
protected int	getCurrentOuterSnapshotVersion()
protected org.apache.flink.api.common.typeutils.TypeSerializer<?>[]	getNestedSerializers(RowSqnInfoSerializer 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

RowSqnInfoSerializerSnapshot

public RowSqnInfoSerializerSnapshot()

Method Detail

getCurrentOuterSnapshotVersion

protected int getCurrentOuterSnapshotVersion()

Specified by:

getCurrentOuterSnapshotVersion in class org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshot<org.apache.flink.table.runtime.sequencedmultisetstate.linked.RowSqnInfo,RowSqnInfoSerializer>

getNestedSerializers

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

Specified by:

getNestedSerializers in class org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshot<org.apache.flink.table.runtime.sequencedmultisetstate.linked.RowSqnInfo,RowSqnInfoSerializer>

createOuterSerializerWithNestedSerializers

protected RowSqnInfoSerializer 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.runtime.sequencedmultisetstate.linked.RowSqnInfo,RowSqnInfoSerializer>