Avro Source () is used to read data stored in Avro file format.

The Avro Source supports the following parameters:

• Input Path
  The path to the Avro file.
  • If omitted, the input path must be supplied as a command-line argument when running the job.
  • For dynamic parameters, FROM_ARGUMENT(arg_name) can be used to pass the input path at runtime.
• Default File System
  The default file system used for the input path, unless the file system is explicitly specified in the path.
• Field(s) Declaration
  Defines the schema of the Avro file to be read, including field names and data types.

Supported Engines

Map Reduce	Spark 1.x RDD	Spark 2.x RDD	Spark 2.x Dataset	Apache Beam 2.29.0 Batch	Apache Beam 2.29.0 Streaming	Apache Flink 1.12.0 Batch	Apache Flink 1.12.0 Streaming	Apache Tez 0.9.1	PySpark