public class MultiInputSplit extends java.lang.Object implements InputSplit, JobConfigurable
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
CASCADING_SOURCE_PATH |
Constructor and Description |
---|
MultiInputSplit()
This constructor is used internally by Hadoop.
|
MultiInputSplit(InputSplit inputSplit,
java.util.Map<java.lang.String,java.lang.String> config) |
Modifier and Type | Method and Description |
---|---|
void |
configure(JobConf jobConf) |
static java.lang.String |
getCurrentTapSourcePath(JobConf jobConf)
Method getCurrentTapSourcePath finds and returns the current source Tap filename path, if any.
|
long |
getLength() |
java.lang.String[] |
getLocations() |
InputSplit |
getWrappedInputSplit() |
void |
readFields(java.io.DataInput in) |
void |
write(java.io.DataOutput out) |
public static final java.lang.String CASCADING_SOURCE_PATH
public MultiInputSplit(InputSplit inputSplit, java.util.Map<java.lang.String,java.lang.String> config)
public MultiInputSplit()
configure(org.apache.hadoop.mapred.JobConf)
and readFields(java.io.DataInput)
are called to properly initialize.public static java.lang.String getCurrentTapSourcePath(JobConf jobConf)
jobConf
- public void configure(JobConf jobConf)
configure
in interface JobConfigurable
public long getLength() throws java.io.IOException
getLength
in interface InputSplit
java.io.IOException
public java.lang.String[] getLocations() throws java.io.IOException
getLocations
in interface InputSplit
java.io.IOException
public InputSplit getWrappedInputSplit()
public void write(java.io.DataOutput out) throws java.io.IOException
public void readFields(java.io.DataInput in) throws java.io.IOException
readFields
in interface Writable
java.io.IOException
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.