Package | Description |
---|---|
com.asakusafw.runtime.stage.collector |
Classes for collecting output data-sets of jobflow execution.
|
Modifier and Type | Method and Description |
---|---|
int |
SortableSlot.compareTo(SortableSlot o) |
int |
SortableSlot.Partitioner.getPartition(SortableSlot key,
Object value,
int numPartitions) |
protected void |
SlotSorter.reduce(SortableSlot key,
Iterable<WritableSlot> values,
org.apache.hadoop.mapreduce.Reducer.Context context) |
protected abstract void |
SlotDistributor.setSlotSpec(T value,
SortableSlot slot)
Sets sorting information into the target slot.
|
Copyright © 2011–2018 Asakusa Framework Team. All rights reserved.