public abstract class SlotSorter extends ReducerWithRuntimeResource<SortableSlot,WritableSlot,Object,Object>
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 and Description |
---|
SlotSorter() |
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) |
run, runInternal
public static final String NAME_GET_OUTPUT_NAMES
getOutputNames()
.public static final String NAME_CREATE_SLOT_OBJECTS
createSlotObjects()
.protected abstract org.apache.hadoop.io.Writable[] createSlotObjects()
protected abstract String[] getOutputNames()
protected void setup(org.apache.hadoop.mapreduce.Reducer.Context context) throws IOException, InterruptedException
setup
in class org.apache.hadoop.mapreduce.Reducer<SortableSlot,WritableSlot,Object,Object>
IOException
InterruptedException
protected void cleanup(org.apache.hadoop.mapreduce.Reducer.Context context) throws IOException, InterruptedException
cleanup
in class org.apache.hadoop.mapreduce.Reducer<SortableSlot,WritableSlot,Object,Object>
IOException
InterruptedException
protected void reduce(SortableSlot key, Iterable<WritableSlot> values, org.apache.hadoop.mapreduce.Reducer.Context context) throws IOException, InterruptedException
reduce
in class org.apache.hadoop.mapreduce.Reducer<SortableSlot,WritableSlot,Object,Object>
IOException
InterruptedException
Copyright © 2011–2019 Asakusa Framework Team. All rights reserved.