org.apache.flink.formats.avro.utils

Class AvroKryoSerializerUtils.JodaLocalTimeSerializer

java.lang.Object

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

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

Enclosing class:

AvroKryoSerializerUtils

public static class AvroKryoSerializerUtils.JodaLocalTimeSerializer
extends com.esotericsoftware.kryo.Serializer<org.joda.time.LocalTime>

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

Constructor Summary

Constructors

Constructor and Description
JodaLocalTimeSerializer()

Method Summary

Modifier and Type	Method and Description
org.joda.time.LocalTime	copy(com.esotericsoftware.kryo.Kryo kryo, org.joda.time.LocalTime original)
org.joda.time.LocalTime	read(com.esotericsoftware.kryo.Kryo kryo, com.esotericsoftware.kryo.io.Input input, Class<org.joda.time.LocalTime> type)
void	write(com.esotericsoftware.kryo.Kryo kryo, com.esotericsoftware.kryo.io.Output output, org.joda.time.LocalTime object)

Methods inherited from class com.esotericsoftware.kryo.Serializer

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

JodaLocalTimeSerializer

public JodaLocalTimeSerializer()

Method Detail

write

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

Specified by:

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

read

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

Specified by:

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

copy

public org.joda.time.LocalTime copy(com.esotericsoftware.kryo.Kryo kryo,
                                    org.joda.time.LocalTime original)

Overrides:

copy in class com.esotericsoftware.kryo.Serializer<org.joda.time.LocalTime>