Package | Description |
---|---|
com.asakusafw.runtime.flow |
Classes for executing data flow operations.
|
com.asakusafw.runtime.stage.collector |
Classes for collecting output data-sets of jobflow execution.
|
com.asakusafw.runtime.stage.directio |
Map Reduce stage elements for Direct I/O.
|
Modifier and Type | Class and Description |
---|---|
class |
SegmentedReducer<KEYIN extends SegmentedWritable,VALUEIN extends SegmentedWritable,KEYOUT extends org.apache.hadoop.io.Writable,VALUEOUT extends org.apache.hadoop.io.Writable>
A skeletal implementation of Hadoop Reducer class which uses
SegmentedWritable as it input key/value. |
Modifier and Type | Class and Description |
---|---|
class |
SlotSorter
A skeletal implementation of Hadoop Reducer for partitioning by their slot.
|
Modifier and Type | Class and Description |
---|---|
class |
DirectOutputReducer
Reducer for direct output.
|
Copyright © 2011–2019 Asakusa Framework Team. All rights reserved.