Package org.apache.flink.formats.avro

Interface Summary

Interface	Description
AvroBuilder<T>	A builder to create an AvroBulkWriter from an OutputStream.
AvroToRowDataConverters.AvroToRowDataConverter	Runtime converter that converts Avro data structures into objects of Flink Table & SQL internal data structures.
RowDataToAvroConverters.RowDataToAvroConverter	Runtime converter that converts objects of Flink Table & SQL internal data structures to corresponding Avro data structures.
SchemaCoder	Schema coder that allows reading schema that is somehow embedded into serialized record.
SchemaCoder.SchemaCoderProvider	Provider for SchemaCoder.

Class Summary

Class	Description
AbstractAvroBulkFormat<A,T,SplitT extends org.apache.flink.connector.file.src.FileSourceSplit>	Provides a BulkFormat for Avro records.
AvroBulkWriter<T>	A simple BulkWriter implementation that wraps an Avro DataFileWriter.
AvroDeserializationSchema<T>	Deserialization schema that deserializes from Avro binary format.
AvroFileFormatFactory	Avro format factory for file system.
AvroFormatFactory	Table format factory for providing configured instances of Avro to RowData SerializationSchema and DeserializationSchema.
AvroFormatOptions	Options for the avro format.
AvroInputFormat<E>	Provides a FileInputFormat for Avro records.
AvroOutputFormat<E>	FileOutputFormat for Avro records.
AvroRowDataDeserializationSchema	Deserialization schema from Avro bytes to RowData.
AvroRowDataSerializationSchema	Serialization schema that serializes RowData into Avro bytes.
AvroRowDeserializationSchema	Deprecated. The format was developed for the Table API users and will not be maintained for DataStream API users anymore.
AvroRowSerializationSchema	Deprecated. The format was developed for the Table API users and will not be maintained for DataStream API users anymore.
AvroSerializationSchema<T>	Serialization schema that serializes to Avro binary format.
AvroToRowDataConverters	Tool class used to convert from Avro GenericRecord to RowData.
AvroWriterFactory<T>	A factory that creates an AvroBulkWriter.
AvroWriters	Convenience builder to create AvroWriterFactory instances for the different Avro types.
RegistryAvroDeserializationSchema<T>	Deserialization schema that deserializes from Avro binary format using SchemaCoder.
RegistryAvroSerializationSchema<T>	Serialization schema that serializes to Avro binary format.
RowDataToAvroConverters	Tool class used to convert from RowData to Avro GenericRecord.

Enum Summary

Enum	Description
AvroOutputFormat.Codec	Wrapper which encapsulates the supported codec and a related serialization byte.