Package | Description |
---|---|
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.
|
com.asakusafw.runtime.stage.preparator |
Copies original flow inputs into temporary area.
|
Modifier and Type | Class and Description |
---|---|
class |
SlotDirectMapper
The skeletal implementation to output values directly.
|
class |
SlotDistributor<T extends org.apache.hadoop.io.Writable>
The skeletal implementation of Hadoop Mapper for distributing values into
SlotSorter . |
Modifier and Type | Class and Description |
---|---|
class |
AbstractDirectOutputMapper<T extends DataModel<T>>
An abstract implementation of each mapper class for direct output.
|
class |
AbstractNoReduceDirectOutputMapper<T>
Mapper which directly creates file for direct output.
|
Modifier and Type | Class and Description |
---|---|
class |
PreparatorMapper<T>
The skeletal implementation to output values directly.
|
Copyright © 2011–2019 Asakusa Framework Team. All rights reserved.