org.apache.hive.hcatalog.mapreduce

Class HCatSplit

java.lang.Object

org.apache.hadoop.mapreduce.InputSplit

org.apache.hive.hcatalog.mapreduce.HCatSplit

All Implemented Interfaces:

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

public class HCatSplit
extends org.apache.hadoop.mapreduce.InputSplit
implements org.apache.hadoop.io.Writable, org.apache.hadoop.mapred.InputSplit

The HCatSplit wrapper around the InputSplit returned by the underlying InputFormat

Constructor Summary

Constructors

Constructor and Description
HCatSplit() Instantiates a new hcat split.
HCatSplit(PartInfo partitionInfo, org.apache.hadoop.mapred.InputSplit baseMapRedSplit) Instantiates a new hcat split.

Method Summary

Modifier and Type	Method and Description
org.apache.hadoop.mapred.InputSplit	getBaseSplit() Gets the underlying InputSplit.
HCatSchema	getDataSchema() Gets the data schema.
long	getLength()
String[]	getLocations()
PartInfo	getPartitionInfo() Gets the partition info.
HCatSchema	getTableSchema() Gets the table schema.
void	readFields(DataInput input)
void	write(DataOutput output)

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

getLocationInfo

Methods inherited from class java.lang.Object

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

Constructor Detail

HCatSplit

public HCatSplit()

Instantiates a new hcat split.

HCatSplit

public HCatSplit(PartInfo partitionInfo,
                 org.apache.hadoop.mapred.InputSplit baseMapRedSplit)

Instantiates a new hcat split.

Parameters:

partitionInfo - the partition info

baseMapRedSplit - the base mapred split

Method Detail

getPartitionInfo

public PartInfo getPartitionInfo()

Gets the partition info.

Returns:

the partitionInfo

getBaseSplit

public org.apache.hadoop.mapred.InputSplit getBaseSplit()

Gets the underlying InputSplit.

Returns:

the baseMapRedSplit

getDataSchema

public HCatSchema getDataSchema()

Gets the data schema.

Returns:

the table schema

getTableSchema

public HCatSchema getTableSchema()

Gets the table schema.

Returns:

the table schema

getLength

public long getLength()

Specified by:

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

Specified by:

getLength in class org.apache.hadoop.mapreduce.InputSplit

getLocations

public String[] getLocations()

Specified by:

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

Specified by:

getLocations in class org.apache.hadoop.mapreduce.InputSplit

readFields

public void readFields(DataInput input)
                throws IOException

Specified by:

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

Throws:

IOException

write

public void write(DataOutput output)
           throws IOException

Specified by:

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

Throws:

IOException