edu.arsc.multisearch
Class ServiceInputFormat
java.lang.Object
org.apache.hadoop.mapred.FileInputFormat<org.apache.hadoop.io.Text,ServiceWritable>
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
Fields inherited from class org.apache.hadoop.mapred.FileInputFormat |
LOG |
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 |
ServiceInputFormat
public ServiceInputFormat()
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