org.apache.avro.mapred
Class AvroInputFormat<T>

java.lang.Object
  extended by org.apache.hadoop.mapred.FileInputFormat<AvroWrapper<T>,NullWritable>
      extended by org.apache.avro.mapred.AvroInputFormat<T>
All Implemented Interfaces:
org.apache.hadoop.mapred.InputFormat<AvroWrapper<T>,NullWritable>

public class AvroInputFormat<T>
extends org.apache.hadoop.mapred.FileInputFormat<AvroWrapper<T>,NullWritable>

An InputFormat for Avro data files


Field Summary
 
Fields inherited from class org.apache.hadoop.mapred.FileInputFormat
LOG
 
Constructor Summary
AvroInputFormat()
           
 
Method Summary
 org.apache.hadoop.mapred.RecordReader<AvroWrapper<T>,NullWritable> getRecordReader(org.apache.hadoop.mapred.InputSplit split, org.apache.hadoop.mapred.JobConf job, org.apache.hadoop.mapred.Reporter reporter)
           
protected  FileStatus[] listStatus(org.apache.hadoop.mapred.JobConf job)
           
 
Methods inherited from class org.apache.hadoop.mapred.FileInputFormat
addInputPath, addInputPaths, computeSplitSize, getBlockIndex, getInputPathFilter, getInputPaths, getSplitHosts, getSplits, isSplitable, setInputPathFilter, setInputPaths, setInputPaths, setMinSplitSize
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

AvroInputFormat

public AvroInputFormat()
Method Detail

listStatus

protected FileStatus[] listStatus(org.apache.hadoop.mapred.JobConf job)
                           throws IOException
Overrides:
listStatus in class org.apache.hadoop.mapred.FileInputFormat<AvroWrapper<T>,NullWritable>
Throws:
IOException

getRecordReader

public org.apache.hadoop.mapred.RecordReader<AvroWrapper<T>,NullWritable> getRecordReader(org.apache.hadoop.mapred.InputSplit split,
                                                                                          org.apache.hadoop.mapred.JobConf job,
                                                                                          org.apache.hadoop.mapred.Reporter reporter)
                                                                                   throws IOException
Specified by:
getRecordReader in interface org.apache.hadoop.mapred.InputFormat<AvroWrapper<T>,NullWritable>
Specified by:
getRecordReader in class org.apache.hadoop.mapred.FileInputFormat<AvroWrapper<T>,NullWritable>
Throws:
IOException


Copyright © 2010 The Apache Software Foundation