public class DefaultSplitCombiner extends SplitCombiner
SplitCombiner
.Modifier and Type | Class and Description |
---|---|
static class |
DefaultSplitCombiner.Configuration
Configuration for
DefaultSplitCombiner . |
SplitCombiner.Util
Constructor and Description |
---|
DefaultSplitCombiner() |
Modifier and Type | Method and Description |
---|---|
protected List<StageInputSplit> |
combine(org.apache.hadoop.mapreduce.JobContext context,
List<StageInputSplit> splits)
Combines
StageInputSplit s. |
protected List<StageInputSplit> combine(org.apache.hadoop.mapreduce.JobContext context, List<StageInputSplit> splits) throws IOException, InterruptedException
SplitCombiner
StageInputSplit
s.combine
in class SplitCombiner
context
- current contextsplits
- the original splitsIOException
- if failed to combine by I/O errorInterruptedException
- if interrupted while combineCopyright © 2011–2018 Asakusa Framework Team. All rights reserved.