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>

Deprecated.

The format was developed for the Table API users and will not be maintained for DataStream API users anymore. Either use Table API or switch to Data Stream, defining your own DeserializationSchema.

@PublicEvolving
 @Deprecated
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

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.api.common.serialization.DeserializationSchema

DeserializationSchema.InitializationContext

Constructor Summary

Constructors

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

Method Summary

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

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

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

deserialize, open

Constructor Detail

AvroRowDeserializationSchema

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

Deprecated.

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)

Deprecated.

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

Deprecated.

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()

Deprecated.

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)

Deprecated.

Overrides:

equals in class Object

hashCode

public int hashCode()

Deprecated.

Overrides:

hashCode in class Object