public abstract class SplitCombiner extends Object
StageInputSplit
s.Modifier and Type | Class and Description |
---|---|
static class |
SplitCombiner.Util
Utilities for
SplitCombiner . |
Constructor and Description |
---|
SplitCombiner() |
Modifier and Type | Method and Description |
---|---|
protected abstract List<StageInputSplit> |
combine(org.apache.hadoop.mapreduce.JobContext context,
List<StageInputSplit> splits)
Combines
StageInputSplit s. |
protected abstract List<StageInputSplit> combine(org.apache.hadoop.mapreduce.JobContext context, List<StageInputSplit> splits) throws IOException, InterruptedException
StageInputSplit
s.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.