K
- V
- public static interface HadoopShims.CombineFileInputFormatShim<K,V>
Modifier and Type | Method and Description |
---|---|
void |
createPool(org.apache.hadoop.mapred.JobConf conf,
org.apache.hadoop.fs.PathFilter... filters) |
org.apache.hadoop.fs.Path[] |
getInputPathsShim(org.apache.hadoop.mapred.JobConf conf) |
org.apache.hadoop.mapred.lib.CombineFileSplit |
getInputSplitShim() |
org.apache.hadoop.mapred.RecordReader |
getRecordReader(org.apache.hadoop.mapred.JobConf job,
org.apache.hadoop.mapred.lib.CombineFileSplit split,
org.apache.hadoop.mapred.Reporter reporter,
Class<org.apache.hadoop.mapred.RecordReader<K,V>> rrClass) |
org.apache.hadoop.mapred.lib.CombineFileSplit[] |
getSplits(org.apache.hadoop.mapred.JobConf job,
int numSplits) |
org.apache.hadoop.fs.Path[] getInputPathsShim(org.apache.hadoop.mapred.JobConf conf)
void createPool(org.apache.hadoop.mapred.JobConf conf, org.apache.hadoop.fs.PathFilter... filters)
org.apache.hadoop.mapred.lib.CombineFileSplit[] getSplits(org.apache.hadoop.mapred.JobConf job, int numSplits) throws IOException
IOException
org.apache.hadoop.mapred.lib.CombineFileSplit getInputSplitShim() throws IOException
IOException
org.apache.hadoop.mapred.RecordReader getRecordReader(org.apache.hadoop.mapred.JobConf job, org.apache.hadoop.mapred.lib.CombineFileSplit split, org.apache.hadoop.mapred.Reporter reporter, Class<org.apache.hadoop.mapred.RecordReader<K,V>> rrClass) throws IOException
IOException
Copyright © 2021 The Apache Software Foundation. All rights reserved.