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