org.apache.hadoop.hive.shims
Interface HadoopShims.CombineFileInputFormatShim<K,V>

Type Parameters:

K -

V -

Enclosing interface:

HadoopShims

public static interface HadoopShims.CombineFileInputFormatShim<K,V>

CombineFileInputFormatShim.

Method Summary

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)
HadoopShims.InputSplitShim	getInputSplitShim()
org.apache.hadoop.mapred.RecordReader	getRecordReader(org.apache.hadoop.mapred.JobConf job, HadoopShims.InputSplitShim split, org.apache.hadoop.mapred.Reporter reporter, Class<org.apache.hadoop.mapred.RecordReader<K,V>> rrClass)
HadoopShims.InputSplitShim[]	getSplits(org.apache.hadoop.mapred.JobConf job, int numSplits)

Method Detail

getInputPathsShim

org.apache.hadoop.fs.Path[] getInputPathsShim(org.apache.hadoop.mapred.JobConf conf)

createPool

void createPool(org.apache.hadoop.mapred.JobConf conf,
                org.apache.hadoop.fs.PathFilter... filters)

getSplits

HadoopShims.InputSplitShim[] getSplits(org.apache.hadoop.mapred.JobConf job,
                                       int numSplits)
                                       throws IOException

Throws:

IOException

getInputSplitShim

HadoopShims.InputSplitShim getInputSplitShim()
                                             throws IOException

Throws:

IOException

getRecordReader

org.apache.hadoop.mapred.RecordReader getRecordReader(org.apache.hadoop.mapred.JobConf job,
                                                      HadoopShims.InputSplitShim split,
                                                      org.apache.hadoop.mapred.Reporter reporter,
                                                      Class<org.apache.hadoop.mapred.RecordReader<K,V>> rrClass)
                                                      throws IOException

Throws:

IOException