org.apache.flink.table.runtime.types

Class CRowSerializerSnapshot

java.lang.Object

org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshot<org.apache.flink.table.runtime.types.CRow,org.apache.flink.table.runtime.types.CRowSerializer>

org.apache.flink.table.runtime.types.CRowSerializerSnapshot

All Implemented Interfaces:

org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<org.apache.flink.table.runtime.types.CRow>

public class CRowSerializerSnapshot
extends org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshot<org.apache.flink.table.runtime.types.CRow,org.apache.flink.table.runtime.types.CRowSerializer>

Snapshot class for CRowSerializer.

Constructor Summary

Constructors

Constructor and Description
CRowSerializerSnapshot() Constructor for read instantiation.
CRowSerializerSnapshot(org.apache.flink.table.runtime.types.CRowSerializer serializerInstance) Constructor to create the snapshot for writing.

Method Summary

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

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

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

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.api.common.typeutils.TypeSerializerSnapshot

readVersionedSnapshot, writeVersionedSnapshot

Constructor Detail

CRowSerializerSnapshot

public CRowSerializerSnapshot()

Constructor for read instantiation.

CRowSerializerSnapshot

public CRowSerializerSnapshot(org.apache.flink.table.runtime.types.CRowSerializer serializerInstance)

Constructor to create the snapshot for writing.

Method Detail

getCurrentOuterSnapshotVersion

protected int getCurrentOuterSnapshotVersion()

Specified by:

getCurrentOuterSnapshotVersion in class org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshot<org.apache.flink.table.runtime.types.CRow,org.apache.flink.table.runtime.types.CRowSerializer>

getNestedSerializers

protected org.apache.flink.api.common.typeutils.TypeSerializer<?>[] getNestedSerializers(org.apache.flink.table.runtime.types.CRowSerializer outerSerializer)

Specified by:

getNestedSerializers in class org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshot<org.apache.flink.table.runtime.types.CRow,org.apache.flink.table.runtime.types.CRowSerializer>

createOuterSerializerWithNestedSerializers

protected org.apache.flink.table.runtime.types.CRowSerializer 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.types.CRow,org.apache.flink.table.runtime.types.CRowSerializer>