This project has retired. For details please refer to its Attic page.

org.apache.crunch.impl.mr.run
Class CrunchInputSplit

java.lang.Object
  org.apache.hadoop.mapreduce.InputSplit
      org.apache.crunch.impl.mr.run.CrunchInputSplit

All Implemented Interfaces:

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

public class CrunchInputSplit
extends org.apache.hadoop.mapreduce.InputSplit
implements org.apache.hadoop.conf.Configurable, org.apache.hadoop.io.Writable

Constructor Summary

CrunchInputSplit()

CrunchInputSplit(org.apache.hadoop.mapreduce.InputSplit inputSplit, Class<? extends org.apache.hadoop.mapreduce.InputFormat> inputFormatClass, Map<String,String> extraConf, int nodeIndex, org.apache.hadoop.conf.Configuration conf)

Method Summary

org.apache.hadoop.conf.Configuration	getConf()
Class<? extends org.apache.hadoop.mapreduce.InputFormat>	getInputFormatClass()
org.apache.hadoop.mapreduce.InputSplit	getInputSplit()
long	getLength()
String[]	getLocations()
int	getNodeIndex()
void	readFields(DataInput in)
void	setConf(org.apache.hadoop.conf.Configuration conf)
void	write(DataOutput out)

Methods inherited from class java.lang.Object

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

Constructor Detail

CrunchInputSplit

public CrunchInputSplit()

CrunchInputSplit

public CrunchInputSplit(org.apache.hadoop.mapreduce.InputSplit inputSplit,
                        Class<? extends org.apache.hadoop.mapreduce.InputFormat> inputFormatClass,
                        Map<String,String> extraConf,
                        int nodeIndex,
                        org.apache.hadoop.conf.Configuration conf)

Method Detail

getNodeIndex

public int getNodeIndex()

getInputSplit

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

getInputFormatClass

public Class<? extends org.apache.hadoop.mapreduce.InputFormat> getInputFormatClass()

getLength

public long getLength()
               throws IOException,
                      InterruptedException

Specified by:

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

Throws:

IOException

InterruptedException

getLocations

public String[] getLocations()
                      throws IOException,
                             InterruptedException

Specified by:

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

Throws:

IOException

InterruptedException

readFields

public void readFields(DataInput in)
                throws IOException

Specified by:

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

Throws:

IOException

write

public void write(DataOutput out)
           throws IOException

Specified by:

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

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