Package org.apache.flink.api.java.typeutils.runtime

Class WritableSerializer.WritableSerializerSnapshot<T extends org.apache.hadoop.io.Writable>

java.lang.Object

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

org.apache.flink.api.java.typeutils.runtime.WritableSerializer.WritableSerializerSnapshot<T>

All Implemented Interfaces:

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

Enclosing class:

WritableSerializer<T extends org.apache.hadoop.io.Writable>

@Internal
public static final class WritableSerializer.WritableSerializerSnapshot<T extends org.apache.hadoop.io.Writable>
extends org.apache.flink.api.common.typeutils.GenericTypeSerializerSnapshot<T,WritableSerializer>

WritableSerializer snapshot class.

Constructor Summary

Constructors

Constructor	Description
WritableSerializerSnapshot()

Method Summary

Modifier and Type	Method	Description
protected org.apache.flink.api.common.typeutils.TypeSerializer<T>	createSerializer(Class<T> typeClass)
protected Class<T>	getTypeClass(WritableSerializer 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

Constructor Detail

WritableSerializerSnapshot

public WritableSerializerSnapshot()

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 org.apache.hadoop.io.Writable,WritableSerializer>

getTypeClass

protected Class<T> getTypeClass(WritableSerializer serializer)

Specified by:

getTypeClass in class org.apache.flink.api.common.typeutils.GenericTypeSerializerSnapshot<T extends org.apache.hadoop.io.Writable,WritableSerializer>

serializerClass

protected Class<?> serializerClass()

Specified by:

serializerClass in class org.apache.flink.api.common.typeutils.GenericTypeSerializerSnapshot<T extends org.apache.hadoop.io.Writable,WritableSerializer>