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, SerializationSchema<T>

Direct Known Subclasses:

ConfluentRegistryAvroSerializationSchema

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

SerializationSchema.InitializationContext

Field Summary

Fields

Modifier and Type	Field and Description
protected SchemaCoder	schemaCoder

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and 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) Serializes the incoming element to a specified type.

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

forGeneric, forSpecific, getDatumWriter, getEncoder, getOutputStream, getSchema

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.api.common.serialization.SerializationSchema

open

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)

Description copied from interface: SerializationSchema

Serializes the incoming element to a specified type.

Specified by:

serialize in interface SerializationSchema<T>

Overrides:

serialize in class AvroSerializationSchema<T>

Parameters:

object - The incoming element to be serialized

Returns:

The serialized element.

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>