Package org.apache.flink.cdc.runtime.serializer

Class MapSerializer.MapSerializerSnapshot<K,V>

java.lang.Object

org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshot<Map<K,V>,MapSerializer<K,V>>

org.apache.flink.cdc.runtime.serializer.MapSerializer.MapSerializerSnapshot<K,V>

All Implemented Interfaces:

org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<Map<K,V>>

Enclosing class:

MapSerializer<K,V>

public static final class MapSerializer.MapSerializerSnapshot<K,V>
extends org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshot<Map<K,V>,MapSerializer<K,V>>

Snapshot class for the MapSerializer.

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
MapSerializerSnapshot()	Constructor for read instantiation.
MapSerializerSnapshot(MapSerializer<K,V> mapSerializer)	Constructor to create the snapshot for writing.

Method Summary

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

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

resolveSchemaCompatibility

Constructor Detail

MapSerializerSnapshot

public MapSerializerSnapshot()

Constructor for read instantiation.

MapSerializerSnapshot

public MapSerializerSnapshot(MapSerializer<K,V> mapSerializer)

Constructor to create the snapshot for writing.

Method Detail

getCurrentOuterSnapshotVersion

public int getCurrentOuterSnapshotVersion()

Specified by:

getCurrentOuterSnapshotVersion in class org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshot<Map<K,V>,MapSerializer<K,V>>

createOuterSerializerWithNestedSerializers

protected MapSerializer<K,V> createOuterSerializerWithNestedSerializers(org.apache.flink.api.common.typeutils.TypeSerializer<?>[] nestedSerializers)

Specified by:

createOuterSerializerWithNestedSerializers in class org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshot<Map<K,V>,MapSerializer<K,V>>

getNestedSerializers

protected org.apache.flink.api.common.typeutils.TypeSerializer<?>[] getNestedSerializers(MapSerializer<K,V> outerSerializer)

Specified by:

getNestedSerializers in class org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshot<Map<K,V>,MapSerializer<K,V>>

getKeySerializerSnapshot

public org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<K> getKeySerializerSnapshot()