Package | Description |
---|---|
com.asakusafw.runtime.stage.input |
Classes for stage inputs.
|
Modifier and Type | Method and Description |
---|---|
List<StageInputSplit.Source> |
StageInputSplit.getSources()
Returns the sources.
|
static Map<Class<? extends org.apache.hadoop.mapreduce.Mapper<?,?,?,?>>,List<StageInputSplit.Source>> |
SplitCombiner.Util.groupByMapper(List<StageInputSplit> splits)
Groups
StageInputSplit s by their own Mapper class. |
Constructor and Description |
---|
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.
|
Copyright © 2011–2018 Asakusa Framework Team. All rights reserved.