cascading.tap.hadoop
Class MultiInputSplit

java.lang.Object
  cascading.tap.hadoop.MultiInputSplit

public class MultiInputSplit
extends Object

Class MultiInputSplit is used by MultiInputFormat

Constructor Summary

MultiInputSplit()

MultiInputSplit(InputSplit inputSplit, Map<String,String> config)

Method Summary

void	configure(JobConf jobConf)
static String	getCurrentTapSourcePath(JobConf jobConf) Method getCurrentTapSourcePath finds and returns the current source Tap filename path, if any.
long	getLength()
String[]	getLocations()
void	readFields(DataInput in)
void	write(DataOutput out)

Methods inherited from class java.lang.Object

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

Constructor Detail

MultiInputSplit

public MultiInputSplit(InputSplit inputSplit,
                       Map<String,String> config)

MultiInputSplit

public MultiInputSplit()

Method Detail

getCurrentTapSourcePath

public static String getCurrentTapSourcePath(JobConf jobConf)

Method getCurrentTapSourcePath finds and returns the current source Tap filename path, if any.

Use this method inside an Operation to find the current file being processed.

Parameters:

jobConf -

Returns:

configure

public void configure(JobConf jobConf)

getLength

public long getLength()
               throws IOException

Throws:

IOException

getLocations

public String[] getLocations()
                      throws IOException

Throws:

IOException

write

public void write(DataOutput out)
           throws IOException

Throws:

IOException

readFields

public void readFields(DataInput in)
                throws IOException

Throws:

IOException