Serialized Form (Flink : Formats : Avro 1.19.1 API)

Package org.apache.flink.formats.avro
- Class org.apache.flink.formats.avro.AbstractAvroBulkFormat extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - readerSchema
```
org.apache.avro.Schema readerSchema
```
- Class org.apache.flink.formats.avro.AvroDeserializationSchema extends Object implements Serializable
  
  serialVersionUID:
  
  -6766681879020862312L
  - Serialized Fields
    - recordClazz
```
Class<T> recordClazz
```
      Class to deserialize to.
    - schemaString
```
String schemaString
```
      Schema in case of GenericRecord for serialization purpose.
    - encoding
```
AvroFormatOptions.AvroEncoding encoding
```
      Config option for the deserialization approach to use.
- Class org.apache.flink.formats.avro.AvroInputFormat extends org.apache.flink.api.common.io.FileInputFormat<E> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - avroValueType
```
Class<T> avroValueType
```
    - reuseAvroValue
```
boolean reuseAvroValue
```
    - lastSync
```
long lastSync
```
- Class org.apache.flink.formats.avro.AvroOutputFormat extends org.apache.flink.api.common.io.FileOutputFormat<E> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
    - writeObject
```
private void writeObject(ObjectOutputStream out)
                  throws IOException
```
      Throws:
      
      IOException
  - Serialized Fields
    - avroValueType
```
Class<T> avroValueType
```
- Class org.apache.flink.formats.avro.AvroRowDataDeserializationSchema extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - nestedSchema
```
org.apache.flink.api.common.serialization.DeserializationSchema<T> nestedSchema
```
      Nested schema to deserialize the inputs into avro GenericRecord. *
    - typeInfo
```
org.apache.flink.api.common.typeinfo.TypeInformation<T> typeInfo
```
      Type information describing the result type.
    - runtimeConverter
```
AvroToRowDataConverters.AvroToRowDataConverter runtimeConverter
```
      Runtime instance that performs the actual work.
- Class org.apache.flink.formats.avro.AvroRowDataSerializationSchema extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - nestedSchema
```
org.apache.flink.api.common.serialization.SerializationSchema<T> nestedSchema
```
      Nested schema to serialize the GenericRecord into bytes. *
    - rowType
```
org.apache.flink.table.types.logical.RowType rowType
```
      Logical type describing the input type.
    - runtimeConverter
```
RowDataToAvroConverters.RowDataToAvroConverter runtimeConverter
```
      Runtime instance that performs the actual work.
- Class org.apache.flink.formats.avro.AvroRowDeserializationSchema extends org.apache.flink.api.common.serialization.AbstractDeserializationSchema<org.apache.flink.types.Row> implements Serializable
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream inputStream)
                 throws ClassNotFoundException,
                        IOException
```
      Deprecated.
      
      Throws:
      
      ClassNotFoundException
      
      IOException
    - writeObject
```
private void writeObject(ObjectOutputStream outputStream)
                  throws IOException
```
      Deprecated.
      
      Throws:
      
      IOException
  - Serialized Fields
    - recordClazz
```
Class<T> recordClazz
```
      Deprecated.
      
      Avro record class for deserialization. Might be null if record class is not available.
    - schemaString
```
String schemaString
```
      Deprecated.
      
      Schema string for deserialization.
- Class org.apache.flink.formats.avro.AvroRowSerializationSchema extends Object implements Serializable
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream inputStream)
                 throws ClassNotFoundException,
                        IOException
```
      Deprecated.
      
      Throws:
      
      ClassNotFoundException
      
      IOException
    - writeObject
```
private void writeObject(ObjectOutputStream outputStream)
                  throws IOException
```
      Deprecated.
      
      Throws:
      
      IOException
  - Serialized Fields
    - recordClazz
```
Class<T> recordClazz
```
      Deprecated.
      
      Avro record class for serialization. Might be null if record class is not available.
    - schemaString
```
String schemaString
```
      Deprecated.
      
      Schema string for deserialization.
- Class org.apache.flink.formats.avro.AvroSerializationSchema extends Object implements Serializable
  
  serialVersionUID:
  
  -8766681879020862312L
  - Serialized Fields
    - recordClazz
```
Class<T> recordClazz
```
      Class to serialize to.
    - schemaString
```
String schemaString
```
    - encoding
```
AvroFormatOptions.AvroEncoding encoding
```
      Config option for the serialization approach to use.
- Class org.apache.flink.formats.avro.AvroWriterFactory extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - avroBuilder
```
AvroBuilder<T> avroBuilder
```
      The builder to construct the Avro DataFileWriter.
- Class org.apache.flink.formats.avro.RegistryAvroDeserializationSchema extends AvroDeserializationSchema<T> implements Serializable
  
  serialVersionUID:
  
  -884738268437806062L
  - Serialized Fields
    - schemaCoderProvider
```
SchemaCoder.SchemaCoderProvider schemaCoderProvider
```
      Provider for schema coder. Used for initializing in each task.
- Class org.apache.flink.formats.avro.RegistryAvroSerializationSchema extends AvroSerializationSchema<T> implements Serializable
  
  serialVersionUID:
  
  -6766681879020862312L
  - Serialized Fields
    - schemaCoderProvider
```
SchemaCoder.SchemaCoderProvider schemaCoderProvider
```
      Provider for schema coder. Used for initializing in each task.
    - schemaCoder
```
SchemaCoder schemaCoder
```
Package org.apache.flink.formats.avro.typeutils
- Class org.apache.flink.formats.avro.typeutils.AvroSerializer extends org.apache.flink.api.common.typeutils.TypeSerializer<T> implements Serializable
  
  serialVersionUID:
  
  2L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException
```
      Throws:
      
      IOException
      
      ClassNotFoundException
  - Serialized Fields
    - type
```
Class<T> type
```
    - schema
```
org.apache.flink.formats.avro.typeutils.SerializableAvroSchema schema
```
    - previousSchema
```
org.apache.flink.formats.avro.typeutils.SerializableAvroSchema previousSchema
```
- Class org.apache.flink.formats.avro.typeutils.AvroTypeInfo extends org.apache.flink.api.java.typeutils.PojoTypeInfo<T extends org.apache.avro.specific.SpecificRecordBase> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.formats.avro.typeutils.GenericRecordAvroTypeInfo extends org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.avro.generic.GenericRecord> implements Serializable
  
  serialVersionUID:
  
  4141977586453820650L
  - Serialization Methods
    - readObject
```
private void readObject(ObjectInputStream ois)
                 throws ClassNotFoundException,
                        IOException
```
      Throws:
      
      ClassNotFoundException
      
      IOException
    - writeObject
```
private void writeObject(ObjectOutputStream oos)
                  throws IOException
```
      Throws:
      
      IOException
Package org.apache.flink.formats.avro.utils
- Class org.apache.flink.formats.avro.utils.AvroKryoSerializerUtils.AvroSchemaSerializer extends com.esotericsoftware.kryo.Serializer<org.apache.avro.Schema> implements Serializable
  
  serialVersionUID:
  
  1L

Serialized Form

Package org.apache.flink.formats.avro

Class org.apache.flink.formats.avro.AbstractAvroBulkFormat extends Object implements Serializable

Serialized Fields

readerSchema

Class org.apache.flink.formats.avro.AvroDeserializationSchema extends Object implements Serializable

Serialized Fields

recordClazz

schemaString

encoding

Class org.apache.flink.formats.avro.AvroInputFormat extends org.apache.flink.api.common.io.FileInputFormat<E> implements Serializable

Serialized Fields

avroValueType

reuseAvroValue

lastSync

Class org.apache.flink.formats.avro.AvroOutputFormat extends org.apache.flink.api.common.io.FileOutputFormat<E> implements Serializable

Serialization Methods

readObject

writeObject

Serialized Fields

avroValueType

Class org.apache.flink.formats.avro.AvroRowDataDeserializationSchema extends Object implements Serializable

Serialized Fields

nestedSchema

typeInfo

runtimeConverter

Class org.apache.flink.formats.avro.AvroRowDataSerializationSchema extends Object implements Serializable

Serialized Fields

nestedSchema

rowType

runtimeConverter

Class org.apache.flink.formats.avro.AvroRowDeserializationSchema extends org.apache.flink.api.common.serialization.AbstractDeserializationSchema<org.apache.flink.types.Row> implements Serializable

Serialization Methods

readObject

writeObject

Serialized Fields

recordClazz

schemaString

Class org.apache.flink.formats.avro.AvroRowSerializationSchema extends Object implements Serializable

Serialization Methods

readObject

writeObject

Serialized Fields

recordClazz

schemaString

Class org.apache.flink.formats.avro.AvroSerializationSchema extends Object implements Serializable

Serialized Fields

recordClazz

schemaString

encoding

Class org.apache.flink.formats.avro.AvroWriterFactory extends Object implements Serializable

Serialized Fields

avroBuilder

Class org.apache.flink.formats.avro.RegistryAvroDeserializationSchema extends AvroDeserializationSchema<T> implements Serializable

Serialized Fields

schemaCoderProvider

Class org.apache.flink.formats.avro.RegistryAvroSerializationSchema extends AvroSerializationSchema<T> implements Serializable

Serialized Fields

schemaCoderProvider

schemaCoder

Package org.apache.flink.formats.avro.typeutils

Class org.apache.flink.formats.avro.typeutils.AvroSerializer extends org.apache.flink.api.common.typeutils.TypeSerializer<T> implements Serializable

Serialization Methods

readObject

Serialized Fields

type

schema

previousSchema

Class org.apache.flink.formats.avro.typeutils.AvroTypeInfo extends org.apache.flink.api.java.typeutils.PojoTypeInfo<T extends org.apache.avro.specific.SpecificRecordBase> implements Serializable

Class org.apache.flink.formats.avro.typeutils.GenericRecordAvroTypeInfo extends org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.avro.generic.GenericRecord> implements Serializable

Serialization Methods

readObject

writeObject

Package org.apache.flink.formats.avro.utils

Class org.apache.flink.formats.avro.utils.AvroKryoSerializerUtils.AvroSchemaSerializer extends com.esotericsoftware.kryo.Serializer<org.apache.avro.Schema> implements Serializable