Class AbstractAvroRecordReader<INPUT_KEY,​INPUT_VALUE>

  • Type Parameters:
    INPUT_KEY - The format of the key as controlled by the input format
    INPUT_VALUE - The format of the value as controlled by the input format
    Direct Known Subclasses:

    public abstract class AbstractAvroRecordReader<INPUT_KEY,​INPUT_VALUE>
    extends AbstractVeniceRecordReader<INPUT_KEY,​INPUT_VALUE>
    An abstraction for a record reader that reads records from input into Avro-serialized keys and values.
    • Constructor Detail

      • AbstractAvroRecordReader

        public AbstractAvroRecordReader​(org.apache.avro.Schema dataSchema,
                                        java.lang.String keyFieldStr,
                                        java.lang.String valueFieldStr,
                                        ETLValueSchemaTransformation etlValueSchemaTransformation,
                                        org.apache.avro.Schema updateSchema)
        This constructor is used when data is read from HDFS.
        dataSchema - Schema of the avro file
        keyFieldStr - Field name of the key field
        valueFieldStr - Field name of the value field
        etlValueSchemaTransformation - The type of transformation that was applied to this schema during ETL. When source data set is not an ETL job, use NONE.