RegistryAvroDeserializationSchema (Flink : Formats : Avro 1.18.1-cp1 API)

java.lang.Object
- org.apache.flink.formats.avro.AvroDeserializationSchema<T>
- - org.apache.flink.formats.avro.RegistryAvroDeserializationSchema<T>

Type Parameters:

T - type of record it produces

All Implemented Interfaces:

Serializable, org.apache.flink.api.common.serialization.DeserializationSchema<T>, org.apache.flink.api.java.typeutils.ResultTypeQueryable<T>
```
public class RegistryAvroDeserializationSchema<T>
extends AvroDeserializationSchema<T>
```
Deserialization schema that deserializes from Avro binary format using SchemaCoder.

See Also:

Serialized Form

Nested Class Summary
- Nested classes/interfaces inherited from interface org.apache.flink.api.common.serialization.DeserializationSchema
  org.apache.flink.api.common.serialization.DeserializationSchema.InitializationContext

Constructor Summary

Constructors
Constructor	Description
`RegistryAvroDeserializationSchema(Class<T> recordClazz, org.apache.avro.Schema reader, SchemaCoder.SchemaCoderProvider schemaCoderProvider)`	Creates Avro deserialization schema that reads schema from input stream using provided `SchemaCoder`.

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type Method Description

T deserialize(byte[] message)

boolean equals(Object o)

int hashCode()
- Methods inherited from class org.apache.flink.formats.avro.AvroDeserializationSchema
  forGeneric, forSpecific, getProducedType, 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
  - RegistryAvroDeserializationSchema
```
public RegistryAvroDeserializationSchema(Class<T> recordClazz,
                                         @Nullable
                                         org.apache.avro.Schema reader,
                                         SchemaCoder.SchemaCoderProvider schemaCoderProvider)
```
    Creates Avro deserialization schema that reads schema from input stream using provided SchemaCoder.
    
    Parameters:
    
    recordClazz - class to which deserialize. Should be either SpecificRecord or GenericRecord.
    
    reader - reader's Avro schema. Should be provided if recordClazz is GenericRecord
    
    schemaCoderProvider - schema provider that allows instantiation of SchemaCoder that will be used for schema reading
- Method Detail
  - deserialize
```
public T deserialize(@Nullable
                     byte[] message)
              throws IOException
```
    Specified by:
    
    deserialize in interface org.apache.flink.api.common.serialization.DeserializationSchema<T>
    
    Overrides:
    
    deserialize in class AvroDeserializationSchema<T>
    
    Throws:
    
    IOException
  - equals
```
public boolean equals(Object o)
```
    Overrides:
    
    equals in class AvroDeserializationSchema<T>
  - hashCode
```
public int hashCode()
```
    Overrides:
    
    hashCode in class AvroDeserializationSchema<T>