Package | Description |
---|---|
com.asakusafw.runtime.flow |
Classes for executing data flow operations.
|
com.asakusafw.runtime.flow.join |
Classes for join algorithm.
|
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.
|
Class and Description |
---|
ListBuffer
A List interface for reusing instances of element objects.
|
ReducerWithRuntimeResource
An abstract super class of a reducer with
RuntimeResource s. |
Rendezvous
An abstract super interface for processing co-group like operations.
|
SegmentedWritable
A
Writable object with its segment ID. |
Class and Description |
---|
FlowResource
Represents a resource used in runtime, and it has resource lifecycle.
|
Class and Description |
---|
MapperWithRuntimeResource
An abstract super class of a mapper with
RuntimeResource s. |
ReducerWithRuntimeResource
An abstract super class of a reducer with
RuntimeResource s. |
Class and Description |
---|
MapperWithRuntimeResource
An abstract super class of a mapper with
RuntimeResource s. |
ReducerWithRuntimeResource
An abstract super class of a reducer with
RuntimeResource s. |
Class and Description |
---|
MapperWithRuntimeResource
An abstract super class of a mapper with
RuntimeResource s. |
Copyright © 2011–2019 Asakusa Framework Team. All rights reserved.