org.apache.flink.formats.avro.typeutils

Class AvroSerializer.AvroSchemaSerializerConfigSnapshot

java.lang.Object

org.apache.flink.core.io.VersionedIOReadableWritable

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

org.apache.flink.formats.avro.typeutils.AvroSerializer.AvroSchemaSerializerConfigSnapshot

All Implemented Interfaces:

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

Enclosing class:

AvroSerializer<T>

public static final class AvroSerializer.AvroSchemaSerializerConfigSnapshot
extends org.apache.flink.api.common.typeutils.TypeSerializerConfigSnapshot

A config snapshot for the Avro Serializer that stores the Avro Schema to check compatibility.

Constructor Summary

Constructors

Constructor and Description
AvroSchemaSerializerConfigSnapshot() Default constructor for instantiation via reflection.
AvroSchemaSerializerConfigSnapshot(String schemaString)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object obj)
String	getSchemaString()
int	getVersion()
int	hashCode()
void	read(org.apache.flink.core.memory.DataInputView in)
String	toString()
void	write(org.apache.flink.core.memory.DataOutputView out)

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, wait, wait, wait

Constructor Detail

AvroSchemaSerializerConfigSnapshot

public AvroSchemaSerializerConfigSnapshot()

Default constructor for instantiation via reflection.

AvroSchemaSerializerConfigSnapshot

public AvroSchemaSerializerConfigSnapshot(String schemaString)

Method Detail

getSchemaString

public String getSchemaString()

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.core.io.VersionedIOReadableWritable

Throws:

IOException

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.core.io.VersionedIOReadableWritable

Throws:

IOException

getVersion

public int getVersion()

equals

public boolean equals(Object obj)

Specified by:

equals in class org.apache.flink.api.common.typeutils.TypeSerializerConfigSnapshot

hashCode

public int hashCode()

Specified by:

hashCode in class org.apache.flink.api.common.typeutils.TypeSerializerConfigSnapshot

toString

public String toString()

Overrides:

toString in class Object