org.apache.flink.formats.avro.utils

Class AvroKryoSerializerUtils.JodaLocalDateSerializer

java.lang.Object

com.esotericsoftware.kryo.Serializer<org.joda.time.LocalDate>

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

Enclosing class:

AvroKryoSerializerUtils

public static class AvroKryoSerializerUtils.JodaLocalDateSerializer
extends com.esotericsoftware.kryo.Serializer<org.joda.time.LocalDate>

Avro logical types use JodaTime's LocalDate but Kryo is unable to serialize it properly (esp. visible after calling the toString() method).

Constructor Summary

Constructors

Constructor and Description
JodaLocalDateSerializer()

Method Summary

Modifier and Type	Method and Description
org.joda.time.LocalDate	read(com.esotericsoftware.kryo.Kryo kryo, com.esotericsoftware.kryo.io.Input input, Class<org.joda.time.LocalDate> aClass)
void	write(com.esotericsoftware.kryo.Kryo kryo, com.esotericsoftware.kryo.io.Output output, org.joda.time.LocalDate localDate)

Methods inherited from class com.esotericsoftware.kryo.Serializer

copy, getAcceptsNull, isImmutable, setAcceptsNull, setGenerics, setImmutable

Methods inherited from class java.lang.Object

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

Constructor Detail

JodaLocalDateSerializer

public JodaLocalDateSerializer()

Method Detail

write

public void write(com.esotericsoftware.kryo.Kryo kryo,
                  com.esotericsoftware.kryo.io.Output output,
                  org.joda.time.LocalDate localDate)

Specified by:

write in class com.esotericsoftware.kryo.Serializer<org.joda.time.LocalDate>

read

public org.joda.time.LocalDate read(com.esotericsoftware.kryo.Kryo kryo,
                                    com.esotericsoftware.kryo.io.Input input,
                                    Class<org.joda.time.LocalDate> aClass)

Specified by:

read in class com.esotericsoftware.kryo.Serializer<org.joda.time.LocalDate>