AvroRowSerializationSchema (Flink : Formats : Avro 1.20.1-cp3 API)

java.lang.Object
- org.apache.flink.formats.avro.AvroRowSerializationSchema

All Implemented Interfaces:

Serializable, org.apache.flink.api.common.serialization.SerializationSchema<org.apache.flink.types.Row>
```
@Deprecated
public class AvroRowSerializationSchema
extends Object
implements org.apache.flink.api.common.serialization.SerializationSchema<org.apache.flink.types.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 SerializationSchema.

Serialization schema that serializes Row into Avro bytes.
Serializes objects that are represented in (nested) Flink rows. It supports types that are compatible with Flink's Table & SQL API.
Note: Changes in this class need to be kept in sync with the corresponding runtime class AvroRowDeserializationSchema and schema converter AvroSchemaConverter.

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

Constructor Summary

Constructors
Constructor	Description
`AvroRowSerializationSchema(Class<? extends org.apache.avro.specific.SpecificRecord> recordClazz)`	Deprecated. Creates an Avro serialization schema for the given specific record class.
`AvroRowSerializationSchema(String avroSchemaString)`	Deprecated. Creates an Avro serialization schema for the given Avro schema string.

Method Summary

All Methods Instance Methods Concrete Methods Deprecated Methods
Modifier and Type	Method	Description
`boolean`	`equals(Object o)`	Deprecated.
`int`	`hashCode()`	Deprecated.
`byte[]`	`serialize(org.apache.flink.types.Row row)`	Deprecated.

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.SerializationSchema
open

- Constructor Detail
  - AvroRowSerializationSchema
```
public AvroRowSerializationSchema(Class<? extends org.apache.avro.specific.SpecificRecord> recordClazz)
```
    Deprecated.
    
    Creates an Avro serialization schema for the given specific record class.
    
    Parameters:
    
    recordClazz - Avro record class used to serialize Flink's row to Avro's record
  - AvroRowSerializationSchema
```
public AvroRowSerializationSchema(String avroSchemaString)
```
    Deprecated.
    
    Creates an Avro serialization schema for the given Avro schema string.
    
    Parameters:
    
    avroSchemaString - Avro schema string used to serialize Flink's row to Avro's record
- Method Detail
  - serialize
```
public byte[] serialize(org.apache.flink.types.Row row)
```
    Deprecated.
    
    Specified by:
    
    serialize in interface org.apache.flink.api.common.serialization.SerializationSchema<org.apache.flink.types.Row>
  - equals
```
public boolean equals(Object o)
```
    Deprecated.
    
    Overrides:
    
    equals in class Object
  - hashCode
```
public int hashCode()
```
    Deprecated.
    
    Overrides:
    
    hashCode in class Object