org.apache.flink.formats.avro.utils

Class AvroKryoSerializerUtils

java.lang.Object

org.apache.flink.api.java.typeutils.AvroUtils

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

public class AvroKryoSerializerUtils
extends org.apache.flink.api.java.typeutils.AvroUtils

Utilities for integrating Avro serializers in Kryo.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AvroKryoSerializerUtils.AvroSchemaSerializer Slow serialization approach for Avro schemas.
static class	AvroKryoSerializerUtils.JodaLocalDateSerializer Avro logical types use JodaTime's LocalDate but Kryo is unable to serialize it properly (esp.
static class	AvroKryoSerializerUtils.JodaLocalTimeSerializer Avro logical types use JodaTime's LocalTime but Kryo is unable to serialize it properly (esp.

Constructor Summary

Constructors

Constructor and Description
AvroKryoSerializerUtils()

Method Summary

Modifier and Type	Method and Description
void	addAvroGenericDataArrayRegistration(LinkedHashMap<String,org.apache.flink.api.java.typeutils.runtime.KryoRegistration> kryoRegistrations)
void	addAvroSerializersIfRequired(org.apache.flink.api.common.ExecutionConfig reg, Class<?> type)
<T> org.apache.flink.api.common.typeutils.TypeSerializer<T>	createAvroSerializer(Class<T> type)
<T> org.apache.flink.api.common.typeinfo.TypeInformation<T>	createAvroTypeInfo(Class<T> type)

Methods inherited from class org.apache.flink.api.java.typeutils.AvroUtils

getAvroUtils

Methods inherited from class java.lang.Object

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

Constructor Detail

AvroKryoSerializerUtils

public AvroKryoSerializerUtils()

Method Detail

addAvroSerializersIfRequired

public void addAvroSerializersIfRequired(org.apache.flink.api.common.ExecutionConfig reg,
                                         Class<?> type)

Specified by:

addAvroSerializersIfRequired in class org.apache.flink.api.java.typeutils.AvroUtils

addAvroGenericDataArrayRegistration

public void addAvroGenericDataArrayRegistration(LinkedHashMap<String,org.apache.flink.api.java.typeutils.runtime.KryoRegistration> kryoRegistrations)

Specified by:

addAvroGenericDataArrayRegistration in class org.apache.flink.api.java.typeutils.AvroUtils

createAvroSerializer

public <T> org.apache.flink.api.common.typeutils.TypeSerializer<T> createAvroSerializer(Class<T> type)

Specified by:

createAvroSerializer in class org.apache.flink.api.java.typeutils.AvroUtils

createAvroTypeInfo

public <T> org.apache.flink.api.common.typeinfo.TypeInformation<T> createAvroTypeInfo(Class<T> type)

Specified by:

createAvroTypeInfo in class org.apache.flink.api.java.typeutils.AvroUtils