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

java.lang.Object
  org.apache.hadoop.mapreduce.InputSplit
      org.apache.hadoop.mapred.FileSplit
          org.apache.hadoop.hive.ql.io.HiveInputFormat.HiveInputSplit

All Implemented Interfaces:

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

Direct Known Subclasses:

BucketizedHiveInputSplit

Enclosing class:

HiveInputFormat<K extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable>

public static class HiveInputFormat.HiveInputSplit
extends org.apache.hadoop.mapred.FileSplit
implements org.apache.hadoop.mapred.InputSplit, org.apache.hadoop.conf.Configurable

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

Constructor Summary

HiveInputFormat.HiveInputSplit()

HiveInputFormat.HiveInputSplit(org.apache.hadoop.mapred.InputSplit inputSplit, String inputFormatClassName)

Method Summary

org.apache.hadoop.conf.Configuration	getConf()
org.apache.hadoop.mapred.InputSplit	getInputSplit()
long	getLength()
String[]	getLocations()
org.apache.hadoop.fs.Path	getPath()
long	getStart() The position of the first byte in the file to process.
String	inputFormatClassName()
void	readFields(DataInput in)
void	setConf(org.apache.hadoop.conf.Configuration conf)
String	toString()
void	write(DataOutput out)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

HiveInputFormat.HiveInputSplit

public HiveInputFormat.HiveInputSplit()

HiveInputFormat.HiveInputSplit

public HiveInputFormat.HiveInputSplit(org.apache.hadoop.mapred.InputSplit inputSplit,
                                      String inputFormatClassName)

Method Detail

getInputSplit

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

inputFormatClassName

public String inputFormatClassName()

getPath

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

Overrides:

getPath in class org.apache.hadoop.mapred.FileSplit

getStart

public long getStart()

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

Overrides:

getStart in class org.apache.hadoop.mapred.FileSplit

toString

public String toString()

Overrides:

toString in class org.apache.hadoop.mapred.FileSplit

getLength

public long getLength()

Specified by:

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

Overrides:

getLength in class org.apache.hadoop.mapred.FileSplit

getLocations

public String[] getLocations()
                      throws IOException

Specified by:

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

Overrides:

getLocations in class org.apache.hadoop.mapred.FileSplit

Throws:

IOException

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.mapred.FileSplit

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.mapred.FileSplit

Throws:

IOException

getConf

public org.apache.hadoop.conf.Configuration getConf()

Specified by:

getConf in interface org.apache.hadoop.conf.Configurable

setConf

public void setConf(org.apache.hadoop.conf.Configuration conf)

Specified by:

setConf in interface org.apache.hadoop.conf.Configurable