edu.arsc.multisearch
Class ServiceInputFormat

java.lang.Object
  extended by org.apache.hadoop.mapred.FileInputFormat<org.apache.hadoop.io.Text,ServiceWritable>
      extended by edu.arsc.multisearch.ServiceInputFormat
All Implemented Interfaces:
org.apache.hadoop.mapred.InputFormat<org.apache.hadoop.io.Text,ServiceWritable>, org.apache.hadoop.mapred.JobConfigurable

public class ServiceInputFormat
extends org.apache.hadoop.mapred.FileInputFormat<org.apache.hadoop.io.Text,ServiceWritable>
implements org.apache.hadoop.mapred.JobConfigurable


Field Summary
 
Fields inherited from class org.apache.hadoop.mapred.FileInputFormat
LOG
 
Constructor Summary
ServiceInputFormat()
           
 
Method Summary
 void configure(org.apache.hadoop.mapred.JobConf conf)
           
 ServiceRecordReader getRecordReader(org.apache.hadoop.mapred.InputSplit genericSplit, org.apache.hadoop.mapred.JobConf job, org.apache.hadoop.mapred.Reporter reporter)
           
protected  boolean isSplitable(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path file)
           
 
Methods inherited from class org.apache.hadoop.mapred.FileInputFormat
addInputPath, addInputPaths, computeSplitSize, getBlockIndex, getInputPathFilter, getInputPaths, getSplits, listPaths, setInputPathFilter, setInputPaths, setInputPaths, setMinSplitSize, validateInput
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ServiceInputFormat

public ServiceInputFormat()
Method Detail

configure

public void configure(org.apache.hadoop.mapred.JobConf conf)
Specified by:
configure in interface org.apache.hadoop.mapred.JobConfigurable

isSplitable

protected boolean isSplitable(org.apache.hadoop.fs.FileSystem fs,
                              org.apache.hadoop.fs.Path file)
Overrides:
isSplitable in class org.apache.hadoop.mapred.FileInputFormat<org.apache.hadoop.io.Text,ServiceWritable>

getRecordReader

public ServiceRecordReader getRecordReader(org.apache.hadoop.mapred.InputSplit genericSplit,
                                           org.apache.hadoop.mapred.JobConf job,
                                           org.apache.hadoop.mapred.Reporter reporter)
                                    throws java.io.IOException
Specified by:
getRecordReader in interface org.apache.hadoop.mapred.InputFormat<org.apache.hadoop.io.Text,ServiceWritable>
Specified by:
getRecordReader in class org.apache.hadoop.mapred.FileInputFormat<org.apache.hadoop.io.Text,ServiceWritable>
Throws:
java.io.IOException