pythonconverters

Type Members

1. class AvroWrapperToJavaConverter extends Converter[Any, Any]

   

   Implementation of org.apache.spark.api.python.Converter that converts an Avro Record wrapped in an AvroKey (or AvroValue) to a Java Map.

   Implementation of org.apache.spark.api.python.Converter that converts an Avro Record wrapped in an AvroKey (or AvroValue) to a Java Map. It tries to work with all 3 Avro data mappings (Generic, Specific and Reflect).

2. class IndexedRecordToJavaConverter extends Converter[IndexedRecord, Map[String, Any]]

   

   Implementation of org.apache.spark.api.python.Converter that converts an Avro IndexedRecord (e.g., derived from AvroParquetInputFormat) to a Java Map.