Package com.asakusafw.runtime.stage.collector

Classes for collecting output data-sets of jobflow execution.

See: Description

Class Summary

Class	Description
SlotDirectMapper	The skeletal implementation to output values directly.
SlotDistributor<T extends org.apache.hadoop.io.Writable>	The skeletal implementation of Hadoop Mapper for distributing values into SlotSorter.
SlotSorter	A skeletal implementation of Hadoop Reducer for partitioning by their slot.
SortableSlot	A sortable data slot.
SortableSlot.Comparator	A comparator for SortableSlot.
SortableSlot.Partitioner	A partitioner for SortableSlot.
WritableSlot	A data slot.

Package com.asakusafw.runtime.stage.collector Description

Classes for collecting output data-sets of jobflow execution. Application developer should not use APIs in this package directly.