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 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.
RegistryAvroSerializationSchema(Class<T> recordClazz, org.apache.avro.Schema schema, SchemaCoder.SchemaCoderProvider schemaCoderProvider, AvroFormatOptions.AvroEncoding encoding)	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 RegistryAvroSerializationSchema<org.apache.avro.generic.GenericRecord>	forGeneric(org.apache.avro.Schema schema, SchemaCoder.SchemaCoderProvider schemaCoderProvider, AvroFormatOptions.AvroEncoding encoding)
static <T extends org.apache.avro.specific.SpecificRecord> RegistryAvroSerializationSchema<T>	forSpecific(Class<T> tClass, SchemaCoder.SchemaCoderProvider schemaCoderProvider)
static <T extends org.apache.avro.specific.SpecificRecord> RegistryAvroSerializationSchema<T>	forSpecific(Class<T> tClass, SchemaCoder.SchemaCoderProvider schemaCoderProvider, AvroFormatOptions.AvroEncoding encoding)
int	hashCode()
byte[]	serialize(T object)

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

forGeneric, forGeneric, forSpecific, 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

RegistryAvroSerializationSchema

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

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

encoding - Avro serialization approach to use.

Method Detail

forSpecific

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

forSpecific

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

forGeneric

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

forGeneric

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

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>