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

Class AvroSerializer.AvroSerializerConfigSnapshot<T>

java.lang.Object

org.apache.flink.core.io.VersionedIOReadableWritable

org.apache.flink.api.common.typeutils.TypeSerializerConfigSnapshot

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

org.apache.flink.api.java.typeutils.runtime.KryoRegistrationSerializerConfigSnapshot<T>

org.apache.flink.api.java.typeutils.runtime.AvroSerializer.AvroSerializerConfigSnapshot<T>

All Implemented Interfaces:

org.apache.flink.core.io.IOReadableWritable, org.apache.flink.core.io.Versioned

Enclosing class:

AvroSerializer<T>

public static class AvroSerializer.AvroSerializerConfigSnapshot<T>
extends org.apache.flink.api.java.typeutils.runtime.KryoRegistrationSerializerConfigSnapshot<T>

Config snapshot for this serializer.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.flink.api.java.typeutils.runtime.KryoRegistrationSerializerConfigSnapshot

org.apache.flink.api.java.typeutils.runtime.KryoRegistrationSerializerConfigSnapshot.DummyKryoSerializerClass<RC>, org.apache.flink.api.java.typeutils.runtime.KryoRegistrationSerializerConfigSnapshot.DummyRegisteredClass

Constructor Summary

Constructors

Constructor and Description
AvroSerializerConfigSnapshot()
AvroSerializerConfigSnapshot(Class<T> baseType, Class<? extends T> typeToInstantiate, LinkedHashMap<String,org.apache.flink.api.java.typeutils.runtime.KryoRegistration> kryoRegistrations)

Method Summary

Modifier and Type	Method and Description
Class<? extends T>	getTypeToInstantiate()
int	getVersion()
void	read(org.apache.flink.core.memory.DataInputView in)
void	write(org.apache.flink.core.memory.DataOutputView out)

Methods inherited from class org.apache.flink.api.java.typeutils.runtime.KryoRegistrationSerializerConfigSnapshot

equals, getKryoRegistrations, hashCode

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

getTypeClass

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

getUserCodeClassLoader, setUserCodeClassLoader

Methods inherited from class org.apache.flink.core.io.VersionedIOReadableWritable

getCompatibleVersions, getReadVersion

Methods inherited from class java.lang.Object

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

Constructor Detail

AvroSerializerConfigSnapshot

public AvroSerializerConfigSnapshot()

AvroSerializerConfigSnapshot

public AvroSerializerConfigSnapshot(Class<T> baseType,
                                    Class<? extends T> typeToInstantiate,
                                    LinkedHashMap<String,org.apache.flink.api.java.typeutils.runtime.KryoRegistration> kryoRegistrations)

Method Detail

write

public void write(org.apache.flink.core.memory.DataOutputView out)
           throws IOException

Specified by:

write in interface org.apache.flink.core.io.IOReadableWritable

Overrides:

write in class org.apache.flink.api.java.typeutils.runtime.KryoRegistrationSerializerConfigSnapshot<T>

Throws:

IOException

read

public void read(org.apache.flink.core.memory.DataInputView in)
          throws IOException

Specified by:

read in interface org.apache.flink.core.io.IOReadableWritable

Overrides:

read in class org.apache.flink.api.java.typeutils.runtime.KryoRegistrationSerializerConfigSnapshot<T>

Throws:

IOException

getVersion

public int getVersion()

getTypeToInstantiate

public Class<? extends T> getTypeToInstantiate()