Package 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	Description
static class	AvroKryoSerializerUtils.AvroSchemaSerializer	Slow serialization approach for Avro schemas.

Constructor Summary

Constructors

Constructor	Description
AvroKryoSerializerUtils()

Method Summary

Modifier and Type	Method	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