org.apache.paimon.flink.utils

Class JavaSerializer.JavaSerializerSnapshot<T extends Serializable>

java.lang.Object

org.apache.flink.api.common.typeutils.GenericTypeSerializerSnapshot<T,JavaSerializer>

org.apache.paimon.flink.utils.JavaSerializer.JavaSerializerSnapshot<T>

All Implemented Interfaces:

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

Enclosing class:

JavaSerializer<T extends Serializable>

public static final class JavaSerializer.JavaSerializerSnapshot<T extends Serializable>
extends org.apache.flink.api.common.typeutils.GenericTypeSerializerSnapshot<T,JavaSerializer>

JavaSerializer snapshot class.

Constructor Summary

Constructors

Constructor and Description
JavaSerializerSnapshot()

Method Summary

Modifier and Type	Method and Description
protected org.apache.flink.api.common.typeutils.TypeSerializer<T>	createSerializer(Class<T> typeClass)
protected Class<T>	getTypeClass(JavaSerializer serializer)
protected Class<?>	serializerClass()

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

getCurrentVersion, readSnapshot, resolveSchemaCompatibility, restoreSerializer, 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, resolveSchemaCompatibility, writeVersionedSnapshot

Constructor Detail

JavaSerializerSnapshot

public JavaSerializerSnapshot()

Method Detail

createSerializer

protected org.apache.flink.api.common.typeutils.TypeSerializer<T> createSerializer(Class<T> typeClass)

Specified by:

createSerializer in class org.apache.flink.api.common.typeutils.GenericTypeSerializerSnapshot<T extends Serializable,JavaSerializer>

getTypeClass

protected Class<T> getTypeClass(JavaSerializer serializer)

Specified by:

getTypeClass in class org.apache.flink.api.common.typeutils.GenericTypeSerializerSnapshot<T extends Serializable,JavaSerializer>

serializerClass

protected Class<?> serializerClass()

Specified by:

serializerClass in class org.apache.flink.api.common.typeutils.GenericTypeSerializerSnapshot<T extends Serializable,JavaSerializer>