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.IOException
HadoopShims.InputSplitShim getInputSplitShim() throws java.io.IOException
java.io.IOException
RecordReader getRecordReader(JobConf job, HadoopShims.InputSplitShim split, Reporter reporter, java.lang.Class<<any>> rrClass) throws java.io.IOException
java.io.IOException
Copyright © 2012 The Apache Software Foundation