com.asakusafw.runtime.stage.collector

Class SlotSorter

java.lang.Object

org.apache.hadoop.mapreduce.Reducer<KEYIN,VALUEIN,KEYOUT,VALUEOUT>

com.asakusafw.runtime.flow.ReducerWithRuntimeResource<SortableSlot,WritableSlot,Object,Object>

com.asakusafw.runtime.stage.collector.SlotSorter

public abstract class SlotSorter
extends ReducerWithRuntimeResource<SortableSlot,WritableSlot,Object,Object>

A skeletal implementation of Hadoop Reducer for partitioning by their slot.

Since:

0.1.0

Version:

0.5.1

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.mapreduce.Reducer

org.apache.hadoop.mapreduce.Reducer.Context

Field Summary

Fields

Modifier and Type	Field and Description
static String	NAME_CREATE_SLOT_OBJECTS The method name of createSlotObjects().
static String	NAME_GET_OUTPUT_NAMES The method name of getOutputNames().

Constructor Summary

Constructors

Constructor and Description
SlotSorter()

Method Summary

Modifier and Type	Method and Description
protected void	cleanup(org.apache.hadoop.mapreduce.Reducer.Context context)
protected abstract org.apache.hadoop.io.Writable[]	createSlotObjects() Returns the array of buffer object for each slot.
protected abstract String[]	getOutputNames() Returns the array of names for each slot.
protected void	reduce(SortableSlot key, Iterable<WritableSlot> values, org.apache.hadoop.mapreduce.Reducer.Context context)
protected void	setup(org.apache.hadoop.mapreduce.Reducer.Context context)

Methods inherited from class com.asakusafw.runtime.flow.ReducerWithRuntimeResource

run, runInternal

Methods inherited from class java.lang.Object

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

Field Detail

NAME_GET_OUTPUT_NAMES

public static final String NAME_GET_OUTPUT_NAMES

The method name of getOutputNames().

See Also:

Constant Field Values

NAME_CREATE_SLOT_OBJECTS

public static final String NAME_CREATE_SLOT_OBJECTS

The method name of createSlotObjects().

See Also:

Constant Field Values

Constructor Detail

SlotSorter

public SlotSorter()

Method Detail

createSlotObjects

protected abstract org.apache.hadoop.io.Writable[] createSlotObjects()

Returns the array of buffer object for each slot.

Returns:

the buffer objects

getOutputNames

protected abstract String[] getOutputNames()

Returns the array of names for each slot.

Returns:

the slot names

setup

protected void setup(org.apache.hadoop.mapreduce.Reducer.Context context)
              throws IOException,
                     InterruptedException

Overrides:

setup in class org.apache.hadoop.mapreduce.Reducer<SortableSlot,WritableSlot,Object,Object>

Throws:

IOException

InterruptedException

cleanup

protected void cleanup(org.apache.hadoop.mapreduce.Reducer.Context context)
                throws IOException,
                       InterruptedException

Overrides:

cleanup in class org.apache.hadoop.mapreduce.Reducer<SortableSlot,WritableSlot,Object,Object>

Throws:

IOException

InterruptedException

reduce

protected void reduce(SortableSlot key,
                      Iterable<WritableSlot> values,
                      org.apache.hadoop.mapreduce.Reducer.Context context)
               throws IOException,
                      InterruptedException

Overrides:

reduce in class org.apache.hadoop.mapreduce.Reducer<SortableSlot,WritableSlot,Object,Object>

Throws:

IOException

InterruptedException