org.apache.flink.formats.avro

Class AvroRowSerializationSchema

java.lang.Object

org.apache.flink.formats.avro.AvroRowSerializationSchema

All Implemented Interfaces:

Serializable, SerializationSchema<Row>

public class AvroRowSerializationSchema
extends Object
implements SerializationSchema<Row>

Serialization schema that serializes Row over SpecificRecord into a Avro bytes.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
AvroRowSerializationSchema(Class<? extends org.apache.avro.specific.SpecificRecord> recordClazz) Creates a Avro serialization schema for the given schema.

Method Summary

Modifier and Type	Method and Description
byte[]	serialize(Row row) Serializes the incoming element to a specified type.

Methods inherited from class java.lang.Object

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

Constructor Detail

AvroRowSerializationSchema

public AvroRowSerializationSchema(Class<? extends org.apache.avro.specific.SpecificRecord> recordClazz)

Creates a Avro serialization schema for the given schema.

Parameters:

recordClazz - Avro record class used to deserialize Avro's record to Flink's row

Method Detail

serialize

public byte[] serialize(Row row)

Description copied from interface: SerializationSchema

Serializes the incoming element to a specified type.

Specified by:

serialize in interface SerializationSchema<Row>

Parameters:

row - The incoming element to be serialized

Returns:

The serialized element.