org.apache.hadoop.hive.shims
Class Hadoop20Shims.CombineFileInputFormatShim<K,V>

java.lang.Object
  org.apache.hadoop.mapred.FileInputFormat<K,V>
      org.apache.hadoop.mapred.lib.CombineFileInputFormat<K,V>
          org.apache.hadoop.hive.shims.Hadoop20Shims.CombineFileInputFormatShim<K,V>

All Implemented Interfaces:

HadoopShims.CombineFileInputFormatShim<K,V>, org.apache.hadoop.mapred.InputFormat<K,V>

Enclosing class:

Hadoop20Shims

public abstract static class Hadoop20Shims.CombineFileInputFormatShim<K,V>
extends org.apache.hadoop.mapred.lib.CombineFileInputFormat<K,V>
implements HadoopShims.CombineFileInputFormatShim<K,V>

Field Summary

Fields inherited from class org.apache.hadoop.mapred.FileInputFormat

LOG

Constructor Summary

Hadoop20Shims.CombineFileInputFormatShim()

Method Summary

void	createPool(org.apache.hadoop.mapred.JobConf conf, PathFilter... filters)
Path[]	getInputPathsShim(org.apache.hadoop.mapred.JobConf conf)
Hadoop20Shims.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)
Hadoop20Shims.InputSplitShim[]	getSplits(org.apache.hadoop.mapred.JobConf job, int numSplits)

Methods inherited from class org.apache.hadoop.mapred.lib.CombineFileInputFormat

createPool, getRecordReader, setMaxSplitSize, setMinSplitSizeNode, setMinSplitSizeRack

Methods inherited from class org.apache.hadoop.mapred.FileInputFormat

addInputPath, addInputPaths, computeSplitSize, getBlockIndex, getInputPathFilter, getInputPaths, getSplitHosts, isSplitable, listStatus, setInputPathFilter, setInputPaths, setInputPaths, setMinSplitSize

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Hadoop20Shims.CombineFileInputFormatShim

public Hadoop20Shims.CombineFileInputFormatShim()

Method Detail

getInputPathsShim

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

Specified by:

getInputPathsShim in interface HadoopShims.CombineFileInputFormatShim<K,V>

createPool

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

Specified by:

createPool in interface HadoopShims.CombineFileInputFormatShim<K,V>

Overrides:

createPool in class org.apache.hadoop.mapred.lib.CombineFileInputFormat<K,V>

getSplits

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

Specified by:

getSplits in interface HadoopShims.CombineFileInputFormatShim<K,V>

Specified by:

getSplits in interface org.apache.hadoop.mapred.InputFormat<K,V>

Overrides:

getSplits in class org.apache.hadoop.mapred.lib.CombineFileInputFormat<K,V>

Throws:

IOException

getInputSplitShim

public Hadoop20Shims.InputSplitShim getInputSplitShim()
                                               throws IOException

Specified by:

getInputSplitShim in interface HadoopShims.CombineFileInputFormatShim<K,V>

Throws:

IOException

getRecordReader

public 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

Specified by:

getRecordReader in interface HadoopShims.CombineFileInputFormatShim<K,V>

Throws:

IOException