org.apache.hadoop.hive.shims

Class HadoopShimsSecure.InputSplitShim

java.lang.Object

org.apache.hadoop.mapreduce.InputSplit

org.apache.hadoop.mapreduce.lib.input.CombineFileSplit

org.apache.hadoop.mapred.lib.CombineFileSplit

org.apache.hadoop.hive.shims.HadoopShimsSecure.InputSplitShim

All Implemented Interfaces:

org.apache.hadoop.io.Writable, org.apache.hadoop.mapred.InputSplit

Direct Known Subclasses:

CombineHiveInputFormat.CombineHiveInputSplit

Enclosing class:

HadoopShimsSecure

public static class HadoopShimsSecure.InputSplitShim
extends org.apache.hadoop.mapred.lib.CombineFileSplit

Constructor Summary

Constructors

Constructor and Description
InputSplitShim()
InputSplitShim(org.apache.hadoop.mapred.JobConf conf, org.apache.hadoop.fs.Path[] paths, long[] startOffsets, long[] lengths, String[] locations)

Method Summary

Modifier and Type	Method and Description
long	getShrinkedLength()
boolean	isShrinked()
void	readFields(DataInput in)
void	shrinkSplit(long length)
void	write(DataOutput out)

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

getJob

Methods inherited from class org.apache.hadoop.mapreduce.lib.input.CombineFileSplit

getLength, getLength, getLengths, getLocations, getNumPaths, getOffset, getPath, getPaths, getStartOffsets, toString

Methods inherited from class org.apache.hadoop.mapreduce.InputSplit

getLocationInfo

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.mapred.InputSplit

getLength, getLocations

Constructor Detail

InputSplitShim

public InputSplitShim()

InputSplitShim

public InputSplitShim(org.apache.hadoop.mapred.JobConf conf,
                      org.apache.hadoop.fs.Path[] paths,
                      long[] startOffsets,
                      long[] lengths,
                      String[] locations)
               throws IOException

Throws:

IOException

Method Detail

shrinkSplit

public void shrinkSplit(long length)

isShrinked

public boolean isShrinked()

getShrinkedLength

public long getShrinkedLength()

readFields

public void readFields(DataInput in)
                throws IOException

Specified by:

readFields in interface org.apache.hadoop.io.Writable

Overrides:

readFields in class org.apache.hadoop.mapreduce.lib.input.CombineFileSplit

Throws:

IOException

write

public void write(DataOutput out)
           throws IOException

Specified by:

write in interface org.apache.hadoop.io.Writable

Overrides:

write in class org.apache.hadoop.mapreduce.lib.input.CombineFileSplit

Throws:

IOException