public static class CombineHiveInputFormat.CombineHiveInputSplit extends java.lang.Object implements HadoopShims.InputSplitShim
Constructor and Description |
---|
CombineHiveInputSplit() |
CombineHiveInputSplit(HadoopShims.InputSplitShim inputSplitShim) |
CombineHiveInputSplit(JobConf job,
HadoopShims.InputSplitShim inputSplitShim) |
Modifier and Type | Method and Description |
---|---|
HadoopShims.InputSplitShim |
getInputSplitShim() |
JobConf |
getJob() |
long |
getLength() |
long |
getLength(int i)
Returns the length of the ith Path.
|
long[] |
getLengths()
Returns an array containing the lengths of the files in the split.
|
java.lang.String[] |
getLocations()
Returns all the Paths where this input-split resides.
|
int |
getNumPaths()
Returns the number of Paths in the split.
|
long |
getOffset(int i)
Returns the start offset of the ith Path.
|
Path |
getPath(int i)
Returns the ith Path.
|
Path[] |
getPaths()
Returns all the Paths in the split.
|
long[] |
getStartOffsets()
Returns an array containing the startoffsets of the files in the split.
|
java.lang.String |
inputFormatClassName()
Returns the inputFormat class name for the i-th chunk.
|
void |
readFields(java.io.DataInput in)
Writable interface.
|
void |
setInputFormatClassName(java.lang.String inputFormatClassName) |
void |
shrinkSplit(long length) |
java.lang.String |
toString()
Prints this obejct as a string.
|
void |
write(java.io.DataOutput out)
Writable interface.
|
public CombineHiveInputSplit() throws java.io.IOException
java.io.IOException
public CombineHiveInputSplit(HadoopShims.InputSplitShim inputSplitShim) throws java.io.IOException
java.io.IOException
public CombineHiveInputSplit(JobConf job, HadoopShims.InputSplitShim inputSplitShim) throws java.io.IOException
java.io.IOException
public HadoopShims.InputSplitShim getInputSplitShim()
public java.lang.String inputFormatClassName()
public void setInputFormatClassName(java.lang.String inputFormatClassName)
public JobConf getJob()
getJob
in interface HadoopShims.InputSplitShim
public long getLength()
getLength
in interface HadoopShims.InputSplitShim
public long[] getStartOffsets()
getStartOffsets
in interface HadoopShims.InputSplitShim
public long[] getLengths()
getLengths
in interface HadoopShims.InputSplitShim
public long getOffset(int i)
getOffset
in interface HadoopShims.InputSplitShim
public long getLength(int i)
getLength
in interface HadoopShims.InputSplitShim
public int getNumPaths()
getNumPaths
in interface HadoopShims.InputSplitShim
public Path getPath(int i)
getPath
in interface HadoopShims.InputSplitShim
public Path[] getPaths()
getPaths
in interface HadoopShims.InputSplitShim
public java.lang.String[] getLocations() throws java.io.IOException
getLocations
in interface HadoopShims.InputSplitShim
java.io.IOException
public java.lang.String toString()
toString
in interface HadoopShims.InputSplitShim
toString
in class java.lang.Object
public void readFields(java.io.DataInput in) throws java.io.IOException
readFields
in interface HadoopShims.InputSplitShim
java.io.IOException
public void write(java.io.DataOutput out) throws java.io.IOException
write
in interface HadoopShims.InputSplitShim
java.io.IOException
public void shrinkSplit(long length)
shrinkSplit
in interface HadoopShims.InputSplitShim
Copyright © 2012 The Apache Software Foundation