Package org.apache.flink.formats.avro.utils

Class AvroKryoSerializerUtils.AvroGenericRecordSerializer

java.lang.Object

com.esotericsoftware.kryo.Serializer<org.apache.avro.generic.GenericData.Record>

org.apache.flink.formats.avro.utils.AvroKryoSerializerUtils.AvroGenericRecordSerializer

All Implemented Interfaces:

Serializable

Enclosing class:

AvroKryoSerializerUtils

public static class AvroKryoSerializerUtils.AvroGenericRecordSerializer
extends com.esotericsoftware.kryo.Serializer<org.apache.avro.generic.GenericData.Record>
implements Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
AvroGenericRecordSerializer()

Method Summary

Modifier and Type	Method	Description
org.apache.avro.generic.GenericData.Record	read(com.esotericsoftware.kryo.Kryo kryo, com.esotericsoftware.kryo.io.Input input, Class<? extends org.apache.avro.generic.GenericData.Record> type)
void	write(com.esotericsoftware.kryo.Kryo kryo, com.esotericsoftware.kryo.io.Output output, org.apache.avro.generic.GenericData.Record record)

Methods inherited from class com.esotericsoftware.kryo.Serializer

copy, getAcceptsNull, isImmutable, setAcceptsNull, setImmutable

Methods inherited from class java.lang.Object

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

Constructor Detail

AvroGenericRecordSerializer

public AvroGenericRecordSerializer()

Method Detail

write

public void write(com.esotericsoftware.kryo.Kryo kryo,
                  com.esotericsoftware.kryo.io.Output output,
                  org.apache.avro.generic.GenericData.Record record)

Specified by:

write in class com.esotericsoftware.kryo.Serializer<org.apache.avro.generic.GenericData.Record>

read

public org.apache.avro.generic.GenericData.Record read(com.esotericsoftware.kryo.Kryo kryo,
                                                       com.esotericsoftware.kryo.io.Input input,
                                                       Class<? extends org.apache.avro.generic.GenericData.Record> type)

Specified by:

read in class com.esotericsoftware.kryo.Serializer<org.apache.avro.generic.GenericData.Record>