Package | Description |
---|---|
com.asakusafw.runtime.stage.input |
Classes for stage inputs.
|
Modifier and Type | Method and Description |
---|---|
protected List<StageInputSplit> |
ExtremeSplitCombiner.combine(org.apache.hadoop.mapreduce.JobContext context,
List<StageInputSplit> splits) |
protected List<StageInputSplit> |
IdentitySplitCombiner.combine(org.apache.hadoop.mapreduce.JobContext context,
List<StageInputSplit> splits) |
protected abstract List<StageInputSplit> |
SplitCombiner.combine(org.apache.hadoop.mapreduce.JobContext context,
List<StageInputSplit> splits)
Combines
StageInputSplit s. |
protected List<StageInputSplit> |
DefaultSplitCombiner.combine(org.apache.hadoop.mapreduce.JobContext context,
List<StageInputSplit> splits) |
Modifier and Type | Method and Description |
---|---|
protected List<StageInputSplit> |
ExtremeSplitCombiner.combine(org.apache.hadoop.mapreduce.JobContext context,
List<StageInputSplit> splits) |
protected List<StageInputSplit> |
IdentitySplitCombiner.combine(org.apache.hadoop.mapreduce.JobContext context,
List<StageInputSplit> splits) |
protected abstract List<StageInputSplit> |
SplitCombiner.combine(org.apache.hadoop.mapreduce.JobContext context,
List<StageInputSplit> splits)
Combines
StageInputSplit s. |
protected List<StageInputSplit> |
DefaultSplitCombiner.combine(org.apache.hadoop.mapreduce.JobContext context,
List<StageInputSplit> splits) |
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. |
Copyright © 2011–2018 Asakusa Framework Team. All rights reserved.