Interface | Description |
---|---|
CommandDispatcher |
a CommandDispatcher receives
Command from upstream
and performs corresponding operations |
DataReceiver |
a DataReceiver pulls in arriving data, an example
is
BufferPuller |
ICombineHandler |
interacts with native side to support Java Combiner
|
INativeComparable |
Any key type that is comparable at native side must implement this interface.
|
INativeHandler |
A Handler accept input, and give output can be used to transfer command and data
|
NativeDataSource |
NativeDataSource loads data from upstream
|
NativeDataTarget |
NativeDataTarge sends data to downstream
|
Class | Description |
---|---|
Command | |
Constants | |
HadoopPlatform | |
NativeBatchProcessor |
used to create channel, transfer data and command between Java and native
|
NativeMapOutputCollectorDelegator<K,V> |
native map output collector wrapped in Java interface
|
NativeRuntime |
This class stands for the native runtime It has three functions:
1.
|
Platform |
Base class for platforms.
|
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
|
TaskContext |
Enum | Description |
---|---|
DataChannel |
Copyright © 2008–2024 Apache Software Foundation. All rights reserved.