public class AvroFileAccessor extends HdfsSplittableDataAccessor
conf, data, inputFormat, iter, jobConf, key, reader
Constructor and Description |
---|
AvroFileAccessor(InputData input)
Constructs a AvroFileAccessor that creates the job configuration and
accesses the avro file to fetch the avro schema
|
Modifier and Type | Method and Description |
---|---|
protected java.lang.Object |
getReader(org.apache.hadoop.mapred.JobConf jobConf,
org.apache.hadoop.mapred.InputSplit split)
Specialized accessors will override this method and implement their own
recordReader.
|
OneRow |
readNextObject()
readNextObject
The AVRO accessor is currently the only specialized accessor that
overrides this method.
|
closeForRead, getNextSplit, isThreadSafe, openForRead
public AvroFileAccessor(InputData input) throws java.lang.Exception
input
- all input parameters coming from the clientjava.lang.Exception
- if getting the avro schema failsprotected java.lang.Object getReader(org.apache.hadoop.mapred.JobConf jobConf, org.apache.hadoop.mapred.InputSplit split) throws java.io.IOException
HdfsSplittableDataAccessor
getReader
in class HdfsSplittableDataAccessor
jobConf
- the hadoop jobconf to use for the selected InputFormatsplit
- the input split to be read by the accessorjava.io.IOException
- if recordreader could not be createdpublic OneRow readNextObject() throws java.io.IOException
readNextObject
in interface ReadAccessor
readNextObject
in class HdfsSplittableDataAccessor
java.io.IOException