Package com.linkedin.venice.hadoop.input.recordreader

Class AbstractVeniceRecordReader<INPUT_KEY,INPUT_VALUE>

java.lang.Object

com.linkedin.venice.hadoop.input.recordreader.AbstractVeniceRecordReader<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:

AbstractAvroRecordReader, IdentityVeniceRecordReader, VeniceVsonRecordReader

public abstract class AbstractVeniceRecordReader<INPUT_KEY,INPUT_VALUE>
extends java.lang.Object

An abstraction for a record reader that reads records from the configured input into Avro-serialized keys and values.

Constructor Summary

Constructors

Constructor	Description
AbstractVeniceRecordReader()

Method Summary

Modifier and Type	Method	Description
protected void	configure(org.apache.avro.Schema keySchema, org.apache.avro.Schema valueSchema)	Configure the record serializers
abstract java.lang.Object	getAvroKey(INPUT_KEY inputKey, INPUT_VALUE inputValue)	Return an Avro output key
abstract java.lang.Object	getAvroValue(INPUT_KEY inputKey, INPUT_VALUE inputValue)	return an Avro output value
byte[]	getKeyBytes(INPUT_KEY inputKey, INPUT_VALUE inputValue)	Return a serialized output key
org.apache.avro.Schema	getKeySchema()
byte[]	getValueBytes(INPUT_KEY inputKey, INPUT_VALUE inputValue)	Return a serialized output value
org.apache.avro.Schema	getValueSchema()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AbstractVeniceRecordReader

public AbstractVeniceRecordReader()

Method Detail

getKeySchema

public org.apache.avro.Schema getKeySchema()

getValueSchema

public org.apache.avro.Schema getValueSchema()

configure

protected void configure(org.apache.avro.Schema keySchema,
                         org.apache.avro.Schema valueSchema)

Configure the record serializers

getAvroKey

public abstract java.lang.Object getAvroKey(INPUT_KEY inputKey,
                                            INPUT_VALUE inputValue)

Return an Avro output key

getAvroValue

public abstract java.lang.Object getAvroValue(INPUT_KEY inputKey,
                                              INPUT_VALUE inputValue)

return an Avro output value

getKeyBytes

public byte[] getKeyBytes(INPUT_KEY inputKey,
                          INPUT_VALUE inputValue)

Return a serialized output key

getValueBytes

public byte[] getValueBytes(INPUT_KEY inputKey,
                            INPUT_VALUE inputValue)

Return a serialized output value