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
HadoopShimsSecure.InputSplitShim()
HadoopShimsSecure.InputSplitShim(org.apache.hadoop.mapred.JobConf conf, org.apache.hadoop.fs.Path[] paths, long[] startOffsets, long[] lengths, String[] locations)

Method Summary

Methods

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

HadoopShimsSecure.InputSplitShim

public HadoopShimsSecure.InputSplitShim()

HadoopShimsSecure.InputSplitShim

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