All Classes and Interfaces

Class
Description
 
load data into a buffer signaled by a BufferPuller
actively signal a BufferPullee to load data into buffer and receive
collect data when signaled
actively push data into a buffer and signal a BufferPushee to collect it
 
read data from a input buffer
DataOutputStream implementation which buffers data in a fixed-size ByteBuffer.
 
 
 
 
a CommandDispatcher receives Command from upstream and performs corresponding operations
 
 
 
 
 
a DataReceiver pulls in arriving data, an example is BufferPuller
 
 
 
 
interacts with native side to support Java Combiner
an IDataLoader loads data on demand
serializes key-value pair
Any key type that is comparable at native side must implement this interface.
A Handler accept input, and give output can be used to transfer command and data
an INativeSerializer serializes and deserializes data transferred between Java and native.
 
 
 
 
 
used to create channel, transfer data and command between Java and native
Java Record Reader + Java Mapper + Native Collector
NativeDataSource loads data from upstream
NativeDataTarge sends data to downstream
native map output collector wrapped in Java interface
This class stands for the native runtime It has three functions: 1.
 
base class of output files manager.
Manipulate the working area for the transient store for maps and reduces.
 
 
 
Base class for platforms.
this class will load in and init all platforms on classpath it is also the facade to check for key type support and other platform methods