org.apache.hcatalog.mapreduce
Class HCatSplit

Object
  InputSplit
      HCatSplit

All Implemented Interfaces:

Writable, InputSplit

public class HCatSplit
extends InputSplit
implements Writable, InputSplit

The HCatSplit wrapper around the InputSplit returned by the underlying InputFormat

Constructor Summary

HCatSplit()
Instantiates a new hcat split.

HCatSplit(PartInfo partitionInfo, InputSplit baseMapRedSplit, HCatSchema tableSchema)
Instantiates a new hcat split.

Method Summary

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 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,
                 InputSplit baseMapRedSplit,
                 HCatSchema tableSchema)

Instantiates a new hcat split.

Parameters:

partitionInfo - the partition info

baseMapRedSplit - the base mapred split

tableSchema - the table level schema

Method Detail

getPartitionInfo

public PartInfo getPartitionInfo()

Gets the partition info.

Returns:

the partitionInfo

getBaseSplit

public 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 InputSplit

Specified by:

getLength in class InputSplit

getLocations

public String[] getLocations()

Specified by:

getLocations in interface InputSplit

Specified by:

getLocations in class InputSplit

readFields

public void readFields(DataInput input)
                throws IOException

Specified by:

readFields in interface Writable

Throws:

IOException

write

public void write(DataOutput output)
           throws IOException

Specified by:

write in interface Writable

Throws:

IOException