org.apache.flink.formats.avro

Class AvroRowDeserializationSchema

java.lang.Object

org.apache.flink.api.common.serialization.AbstractDeserializationSchema<Row>

org.apache.flink.formats.avro.AvroRowDeserializationSchema

All Implemented Interfaces:

Serializable, DeserializationSchema<Row>, ResultTypeQueryable<Row>

public class AvroRowDeserializationSchema
extends AbstractDeserializationSchema<Row>

Deserialization schema from Avro bytes over SpecificRecord to Row.

Deserializes the byte[] messages into (nested) Flink Rows. Utf8 is converted to regular Java Strings.

See Also:

Serialized Form

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
Row	deserialize(byte[] message) De-serializes the byte message.

Methods inherited from class org.apache.flink.api.common.serialization.AbstractDeserializationSchema

getProducedType, isEndOfStream

Methods inherited from class java.lang.Object

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

Constructor Detail

AvroRowDeserializationSchema

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

Creates a Avro deserialization schema for the given record.

Parameters:

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

Method Detail

deserialize

public Row deserialize(byte[] message)
                throws IOException

Description copied from class: AbstractDeserializationSchema

De-serializes the byte message.

Specified by:

deserialize in interface DeserializationSchema<Row>

Specified by:

deserialize in class AbstractDeserializationSchema<Row>

Parameters:

message - The message, as a byte array.

Returns:

The de-serialized message as an object.

Throws:

IOException