K - V - public static interface HadoopShims.CombineFileInputFormatShim<K,V>
| Modifier and Type | Method and Description |
|---|---|
void |
createPool(JobConf conf,
PathFilter... filters) |
Path[] |
getInputPathsShim(JobConf conf) |
HadoopShims.InputSplitShim |
getInputSplitShim() |
RecordReader |
getRecordReader(JobConf job,
HadoopShims.InputSplitShim split,
Reporter reporter,
java.lang.Class<<any>> rrClass) |
HadoopShims.InputSplitShim[] |
getSplits(JobConf job,
int numSplits) |
Path[] getInputPathsShim(JobConf conf)
void createPool(JobConf conf,
PathFilter... filters)
HadoopShims.InputSplitShim[] getSplits(JobConf job, int numSplits) throws java.io.IOException
java.io.IOExceptionHadoopShims.InputSplitShim getInputSplitShim() throws java.io.IOException
java.io.IOExceptionRecordReader getRecordReader(JobConf job,
HadoopShims.InputSplitShim split,
Reporter reporter,
java.lang.Class<<any>> rrClass)
throws java.io.IOException
java.io.IOExceptionCopyright © 2012 The Apache Software Foundation