org.apache.hadoop.hive.shims
Class HadoopShimsSecure.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.HadoopShimsSecure.CombineFileInputFormatShim<K,V>

All Implemented Interfaces:

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

Enclosing class:

HadoopShimsSecure

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

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.mapred.FileInputFormat

org.apache.hadoop.mapred.FileInputFormat.Counter

Field Summary

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

LOG

Constructor Summary

HadoopShimsSecure.CombineFileInputFormatShim()

Method Summary

void	createPool(org.apache.hadoop.mapred.JobConf conf, PathFilter... filters)
Path[]	getInputPathsShim(org.apache.hadoop.mapred.JobConf conf)
HadoopShimsSecure.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)
HadoopShimsSecure.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

HadoopShimsSecure.CombineFileInputFormatShim

public HadoopShimsSecure.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 HadoopShimsSecure.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 HadoopShimsSecure.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