Package com.asakusafw.runtime.flow

Classes for executing data flow operations.

See: Description

Interface Summary

Interface	Description
FlowResource	Represents a resource used in runtime, and it has resource lifecycle.
ListBuffer<E>	A List interface for reusing instances of element objects.
SegmentedWritable	A Writable object with its segment ID.

Class Summary

Class	Description
ArrayListBuffer<E>	Implementation of ListBuffer using an array.
FileMapListBuffer<E extends org.apache.hadoop.io.Writable>	An implementation of ListBuffer which may spill contents into backing temporary files.
MapperWithRuntimeResource<KEYIN,VALUEIN,KEYOUT,VALUEOUT>	An abstract super class of a mapper with RuntimeResources.
ReducerWithRuntimeResource<KEYIN,VALUEIN,KEYOUT,VALUEOUT>	An abstract super class of a reducer with RuntimeResources.
Rendezvous<V extends org.apache.hadoop.io.Writable>	An abstract super interface for processing co-group like operations.
ResultOutput<T>	An implementation of Result which put data model objects into the final output.
RuntimeResourceManager	Manages lifecycle of RuntimeResource objects.
SegmentedCombiner<KEY extends SegmentedWritable,VALUE extends SegmentedWritable>	A skeletal implementation of Hadoop Combiner class which uses SegmentedWritable as it key/value.
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.
VoidResult<T>	An implementation of Result that discards all results.

Exception Summary

Exception	Description
BufferException	Thrown when a buffer failed its operation.

Package com.asakusafw.runtime.flow Description

Classes for executing data flow operations. Application developer should not use APIs in this package directly.