public class StageInputSplit
extends org.apache.hadoop.mapreduce.InputSplit
implements org.apache.hadoop.io.Writable, org.apache.hadoop.conf.Configurable
InputSplit
for handling multiple Map operations.Modifier and Type | Class and Description |
---|---|
static class |
StageInputSplit.Source
Represents a pair of
InputSplit and its InputFormat class. |
Constructor and Description |
---|
StageInputSplit()
Creates a new instance for the serialization framework.
|
StageInputSplit(Class<? extends org.apache.hadoop.mapreduce.Mapper<?,?,?,?>> mapperClass,
List<StageInputSplit.Source> sources)
Creates a new instance.
|
StageInputSplit(Class<? extends org.apache.hadoop.mapreduce.Mapper<?,?,?,?>> mapperClass,
List<StageInputSplit.Source> sources,
String[] locations)
Creates a new instance.
|
StageInputSplit(org.apache.hadoop.mapreduce.InputSplit original,
Class<? extends org.apache.hadoop.mapreduce.InputFormat<?,?>> formatClass,
Class<? extends org.apache.hadoop.mapreduce.Mapper<?,?,?,?>> mapperClass)
Deprecated.
Use
StageInputSplit(Class, List) instead |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.conf.Configuration |
getConf() |
Class<? extends org.apache.hadoop.mapreduce.InputFormat<?,?>> |
getFormatClass()
Deprecated.
Use
getSources() instead. |
long |
getLength() |
String[] |
getLocations() |
Class<? extends org.apache.hadoop.mapreduce.Mapper<?,?,?,?>> |
getMapperClass()
Returns the mapper class for handling this.
|
org.apache.hadoop.mapreduce.InputSplit |
getOriginal()
Deprecated.
Use
getSources() instead. |
List<StageInputSplit.Source> |
getSources()
Returns the sources.
|
void |
readFields(DataInput in) |
void |
setConf(org.apache.hadoop.conf.Configuration conf) |
void |
write(DataOutput out) |
public StageInputSplit()
@Deprecated public StageInputSplit(org.apache.hadoop.mapreduce.InputSplit original, Class<? extends org.apache.hadoop.mapreduce.InputFormat<?,?>> formatClass, Class<? extends org.apache.hadoop.mapreduce.Mapper<?,?,?,?>> mapperClass)
StageInputSplit(Class, List)
insteadoriginal
- the actual InputSplit
formatClass
- the InputFormat
for handling this splitmapperClass
- the Mapper
for handling this splitIllegalArgumentException
- if some parameters are null
public StageInputSplit(Class<? extends org.apache.hadoop.mapreduce.Mapper<?,?,?,?>> mapperClass, List<StageInputSplit.Source> sources)
mapperClass
- target mapper classsources
- input format and splitsIllegalArgumentException
- if some parameters were null
public StageInputSplit(Class<? extends org.apache.hadoop.mapreduce.Mapper<?,?,?,?>> mapperClass, List<StageInputSplit.Source> sources, String[] locations)
mapperClass
- target mapper classsources
- input format and splitslocations
- hint for locations (nullable)IllegalArgumentException
- if some parameters were null
public long getLength() throws IOException, InterruptedException
getLength
in class org.apache.hadoop.mapreduce.InputSplit
IOException
InterruptedException
public String[] getLocations() throws IOException, InterruptedException
getLocations
in class org.apache.hadoop.mapreduce.InputSplit
IOException
InterruptedException
@Deprecated public org.apache.hadoop.mapreduce.InputSplit getOriginal()
getSources()
instead.@Deprecated public Class<? extends org.apache.hadoop.mapreduce.InputFormat<?,?>> getFormatClass()
getSources()
instead.public List<StageInputSplit.Source> getSources()
public Class<? extends org.apache.hadoop.mapreduce.Mapper<?,?,?,?>> getMapperClass()
public void write(DataOutput out) throws IOException
write
in interface org.apache.hadoop.io.Writable
IOException
public void readFields(DataInput in) throws IOException
readFields
in interface org.apache.hadoop.io.Writable
IOException
public void setConf(org.apache.hadoop.conf.Configuration conf)
setConf
in interface org.apache.hadoop.conf.Configurable
public org.apache.hadoop.conf.Configuration getConf()
getConf
in interface org.apache.hadoop.conf.Configurable
Copyright © 2011–2018 Asakusa Framework Team. All rights reserved.