org.apache.hadoop.hive.ql.io

Class BucketizedHiveInputSplit

java.lang.Object

org.apache.hadoop.mapreduce.InputSplit

org.apache.hadoop.mapred.FileSplit

org.apache.hadoop.hive.ql.io.HiveInputFormat.HiveInputSplit

org.apache.hadoop.hive.ql.io.BucketizedHiveInputSplit

All Implemented Interfaces:

org.apache.hadoop.conf.Configurable, org.apache.hadoop.io.Writable, org.apache.hadoop.mapred.InputSplit, org.apache.hadoop.mapred.InputSplitWithLocationInfo

public class BucketizedHiveInputSplit
extends HiveInputFormat.HiveInputSplit

HiveInputSplit encapsulates an InputSplit with its corresponding inputFormatClass. The reason that it derives from FileSplit is to make sure "map.input.file" in MapTask.

Field Summary

Fields

Modifier and Type	Field and Description
protected String	inputFormatClassName
protected org.apache.hadoop.mapred.InputSplit[]	inputSplits

Constructor Summary

Constructors

Constructor and Description
BucketizedHiveInputSplit()
BucketizedHiveInputSplit(org.apache.hadoop.mapred.InputSplit[] inputSplits, String inputFormatClassName)

Method Summary

Methods

Modifier and Type	Method and Description
String	getInputFormatClassName()
long	getLength()
long	getLength(int idx)
String[]	getLocations()
int	getNumSplits()
org.apache.hadoop.fs.Path	getPath()
org.apache.hadoop.mapred.InputSplit	getSplit(int idx)
long	getStart() The position of the first byte in the file to process.
String	inputFormatClassName()
void	readFields(DataInput in)
void	setInputFormatClassName(String inputFormatClassName)
String	toString()
void	write(DataOutput out)

Methods inherited from class org.apache.hadoop.hive.ql.io.HiveInputFormat.HiveInputSplit

getConf, getInputSplit, setConf

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

getLocationInfo

Methods inherited from class java.lang.Object

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

Field Detail

inputSplits

protected org.apache.hadoop.mapred.InputSplit[] inputSplits

inputFormatClassName

protected String inputFormatClassName

Constructor Detail

BucketizedHiveInputSplit

public BucketizedHiveInputSplit()

BucketizedHiveInputSplit

public BucketizedHiveInputSplit(org.apache.hadoop.mapred.InputSplit[] inputSplits,
                        String inputFormatClassName)

Method Detail

getInputFormatClassName

public String getInputFormatClassName()

setInputFormatClassName

public void setInputFormatClassName(String inputFormatClassName)

getNumSplits

public int getNumSplits()

getSplit

public org.apache.hadoop.mapred.InputSplit getSplit(int idx)

inputFormatClassName

public String inputFormatClassName()

Overrides:

inputFormatClassName in class HiveInputFormat.HiveInputSplit

getPath

public org.apache.hadoop.fs.Path getPath()

Overrides:

getPath in class HiveInputFormat.HiveInputSplit

getStart

public long getStart()

The position of the first byte in the file to process.

Overrides:

getStart in class HiveInputFormat.HiveInputSplit

toString

public String toString()

Overrides:

toString in class HiveInputFormat.HiveInputSplit

getLength

public long getLength()

Specified by:

getLength in interface org.apache.hadoop.mapred.InputSplit

Overrides:

getLength in class HiveInputFormat.HiveInputSplit

getLength

public long getLength(int idx)

getLocations

public String[] getLocations()
                      throws IOException

Specified by:

getLocations in interface org.apache.hadoop.mapred.InputSplit

Overrides:

getLocations in class HiveInputFormat.HiveInputSplit

Throws:

IOException

readFields

public void readFields(DataInput in)
                throws IOException

Specified by:

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

Overrides:

readFields in class HiveInputFormat.HiveInputSplit

Throws:

IOException

write

public void write(DataOutput out)
           throws IOException

Specified by:

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

Overrides:

write in class HiveInputFormat.HiveInputSplit

Throws:

IOException