public static final class JavaSerializer.JavaSerializerSnapshot<T extends Serializable> extends org.apache.flink.api.common.typeutils.GenericTypeSerializerSnapshot<T,JavaSerializer>
JavaSerializer
snapshot class.Constructor and Description |
---|
JavaSerializerSnapshot() |
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() |
getCurrentVersion, readSnapshot, resolveSchemaCompatibility, restoreSerializer, writeSnapshot
protected org.apache.flink.api.common.typeutils.TypeSerializer<T> createSerializer(Class<T> typeClass)
createSerializer
in class org.apache.flink.api.common.typeutils.GenericTypeSerializerSnapshot<T extends Serializable,JavaSerializer>
protected Class<T> getTypeClass(JavaSerializer serializer)
getTypeClass
in class org.apache.flink.api.common.typeutils.GenericTypeSerializerSnapshot<T extends Serializable,JavaSerializer>
protected Class<?> serializerClass()
serializerClass
in class org.apache.flink.api.common.typeutils.GenericTypeSerializerSnapshot<T extends Serializable,JavaSerializer>
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.