com.asakusafw.runtime.stage.input

Class DefaultSplitCombiner

java.lang.Object

com.asakusafw.runtime.stage.input.SplitCombiner

com.asakusafw.runtime.stage.input.DefaultSplitCombiner

public class DefaultSplitCombiner
extends SplitCombiner

A default implementation of SplitCombiner.

Since:

0.2.6

Version:

0.7.0

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	DefaultSplitCombiner.Configuration Configuration for DefaultSplitCombiner.

Nested classes/interfaces inherited from class com.asakusafw.runtime.stage.input.SplitCombiner

SplitCombiner.Util

Constructor Summary

Constructors

Constructor and Description
DefaultSplitCombiner()

Method Summary

Modifier and Type	Method and Description
protected List<StageInputSplit>	combine(org.apache.hadoop.mapreduce.JobContext context, List<StageInputSplit> splits) Combines StageInputSplits.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DefaultSplitCombiner

public DefaultSplitCombiner()

Method Detail

combine

protected List<StageInputSplit> combine(org.apache.hadoop.mapreduce.JobContext context,
                                        List<StageInputSplit> splits)
                                 throws IOException,
                                        InterruptedException

Description copied from class: SplitCombiner

Combines StageInputSplits.

Specified by:

combine in class SplitCombiner

Parameters:

context - current context

splits - the original splits

Returns:

the combined splits

Throws:

IOException - if failed to combine by I/O error

InterruptedException - if interrupted while combine