Package org.apache.flink.formats.avro

Class RegistryAvroSerializationSchema<T>

java.lang.Object

org.apache.flink.formats.avro.AvroSerializationSchema<T>

org.apache.flink.formats.avro.RegistryAvroSerializationSchema<T>

Type Parameters:

T - the type to be serialized

All Implemented Interfaces:

Serializable, org.apache.flink.api.common.serialization.SerializationSchema<T>

public class RegistryAvroSerializationSchema<T>
extends AvroSerializationSchema<T>

Serialization schema that serializes to Avro binary format.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.api.common.serialization.SerializationSchema

org.apache.flink.api.common.serialization.SerializationSchema.InitializationContext

Field Summary

Fields

Modifier and Type	Field	Description
protected SchemaCoder	schemaCoder

Constructor Summary

Constructors

Constructor	Description
RegistryAvroSerializationSchema(Class<T> recordClazz, org.apache.avro.Schema schema, SchemaCoder.SchemaCoderProvider schemaCoderProvider)	Creates a Avro serialization schema.

Method Summary

Modifier and Type	Method	Description
protected void	checkAvroInitialized()
boolean	equals(Object o)
static RegistryAvroSerializationSchema<org.apache.avro.generic.GenericRecord>	forGeneric(org.apache.avro.Schema schema, SchemaCoder.SchemaCoderProvider schemaCoderProvider)
static <T extends org.apache.avro.specific.SpecificRecord> RegistryAvroSerializationSchema<T>	forSpecific(Class<T> tClass, SchemaCoder.SchemaCoderProvider schemaCoderProvider)
int	hashCode()
byte[]	serialize(T object)

Methods inherited from class org.apache.flink.formats.avro.AvroSerializationSchema

forGeneric, forSpecific, getDatumWriter, getEncoder, getOutputStream, getSchema, open

Methods inherited from class java.lang.Object

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

Field Detail

schemaCoder

protected SchemaCoder schemaCoder

Constructor Detail

RegistryAvroSerializationSchema

public RegistryAvroSerializationSchema(Class<T> recordClazz,
                                       org.apache.avro.Schema schema,
                                       SchemaCoder.SchemaCoderProvider schemaCoderProvider)

Creates a Avro serialization schema.

Parameters:

recordClazz - class to serialize. Should be either SpecificRecord or GenericRecord.

schema - writers's Avro schema. Should be provided if recordClazz is GenericRecord

schemaCoderProvider - schema provider that allows instantiation of SchemaCoder that will be used for schema writing

Method Detail

forSpecific

public static <T extends org.apache.avro.specific.SpecificRecord> RegistryAvroSerializationSchema<T> forSpecific(Class<T> tClass,
                                                                                                                 SchemaCoder.SchemaCoderProvider schemaCoderProvider)

forGeneric

public static RegistryAvroSerializationSchema<org.apache.avro.generic.GenericRecord> forGeneric(org.apache.avro.Schema schema,
                                                                                                SchemaCoder.SchemaCoderProvider schemaCoderProvider)

serialize

public byte[] serialize(T object)

Specified by:

serialize in interface org.apache.flink.api.common.serialization.SerializationSchema<T>

Overrides:

serialize in class AvroSerializationSchema<T>

checkAvroInitialized

protected void checkAvroInitialized()

Overrides:

checkAvroInitialized in class AvroSerializationSchema<T>

equals

public boolean equals(Object o)

Overrides:

equals in class AvroSerializationSchema<T>

hashCode

public int hashCode()

Overrides:

hashCode in class AvroSerializationSchema<T>