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>

@PublicEvolving
public class AvroRowDeserializationSchema
extends AbstractDeserializationSchema<Row>

Deserialization schema from Avro bytes to Row.

Deserializes the byte[] messages into (nested) Flink rows. It converts Avro types into types that are compatible with Flink's Table & SQL API.

Projects with Avro records containing logical date/time types need to add a JodaTime dependency.

Note: Changes in this class need to be kept in sync with the corresponding runtime class AvroRowSerializationSchema and schema converter AvroSchemaConverter.

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 specific record class.
AvroRowDeserializationSchema(String avroSchemaString) Creates a Avro deserialization schema for the given Avro schema string.

Method Summary

Modifier and Type	Method and Description
Row	deserialize(byte[] message) De-serializes the byte message.
boolean	equals(Object o)
TypeInformation<Row>	getProducedType() Gets the type produced by this deserializer.
int	hashCode()

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

isEndOfStream

Methods inherited from class java.lang.Object

clone, finalize, getClass, 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 specific record class. Having the concrete Avro record class might improve performance.

Parameters:

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

AvroRowDeserializationSchema

public AvroRowDeserializationSchema(String avroSchemaString)

Creates a Avro deserialization schema for the given Avro schema string.

Parameters:

avroSchemaString - Avro schema string 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

getProducedType

public TypeInformation<Row> getProducedType()

Description copied from class: AbstractDeserializationSchema

Gets the type produced by this deserializer. This is the type that was passed to the constructor, or reflectively inferred (if the default constructor was called).

Specified by:

getProducedType in interface ResultTypeQueryable<Row>

Overrides:

getProducedType in class AbstractDeserializationSchema<Row>

Returns:

The data type produced by this function or input format.

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object