org.apache.hadoop.mapred.nativetask

Class NativeBatchProcessor

java.lang.Object

org.apache.hadoop.mapred.nativetask.NativeBatchProcessor

All Implemented Interfaces:

INativeHandler, NativeDataSource, NativeDataTarget

@InterfaceAudience.Private
public class NativeBatchProcessor
extends Object
implements INativeHandler

used to create channel, transfer data and command between Java and native

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	NativeBatchProcessor(String nativeHandlerName, InputBuffer input, OutputBuffer output)

Method Summary

Modifier and Type	Method and Description
ReadWriteBuffer	call(Command command, ReadWriteBuffer parameter) call command to downstream
void	close() close the native handler
static INativeHandler	create(String nativeHandlerName, org.apache.hadoop.conf.Configuration conf, DataChannel channel)
protected void	finishOutput()
void	finishSendData() Sends a signal that there is no more data
InputBuffer	getInputBuffer() get input buffer
long	getNativeHandler()
OutputBuffer	getOutputBuffer() Gets the output buffer.
void	init(org.apache.hadoop.conf.Configuration conf) init the native handler
void	loadData() load data from upstream
String	name()
void	sendData() Sends a signal to indicate that the data has been stored in output buffer
void	setCommandDispatcher(CommandDispatcher handler)
void	setDataReceiver(DataReceiver handler) set listener.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

NativeBatchProcessor

protected NativeBatchProcessor(String nativeHandlerName,
                               InputBuffer input,
                               OutputBuffer output)
                        throws IOException

Throws:

IOException

Method Detail

create

public static INativeHandler create(String nativeHandlerName,
                                    org.apache.hadoop.conf.Configuration conf,
                                    DataChannel channel)
                             throws IOException

Throws:

IOException

setCommandDispatcher

public void setCommandDispatcher(CommandDispatcher handler)

Specified by:

setCommandDispatcher in interface INativeHandler

init

public void init(org.apache.hadoop.conf.Configuration conf)
          throws IOException

Description copied from interface: INativeHandler

init the native handler

Specified by:

init in interface INativeHandler

Throws:

IOException

close

public void close()
           throws IOException

Description copied from interface: INativeHandler

close the native handler

Specified by:

close in interface INativeHandler

Throws:

IOException

getNativeHandler

public long getNativeHandler()

Specified by:

getNativeHandler in interface INativeHandler

call

public ReadWriteBuffer call(Command command,
                            ReadWriteBuffer parameter)
                     throws IOException

Description copied from interface: INativeHandler

call command to downstream

Specified by:

call in interface INativeHandler

Throws:

IOException

sendData

public void sendData()
              throws IOException

Description copied from interface: NativeDataTarget

Sends a signal to indicate that the data has been stored in output buffer

Specified by:

sendData in interface NativeDataTarget

Throws:

IOException

finishSendData

public void finishSendData()
                    throws IOException

Description copied from interface: NativeDataTarget

Sends a signal that there is no more data

Specified by:

finishSendData in interface NativeDataTarget

Throws:

IOException

finishOutput

protected void finishOutput()

getInputBuffer

public InputBuffer getInputBuffer()

Description copied from interface: NativeDataSource

get input buffer

Specified by:

getInputBuffer in interface NativeDataSource

getOutputBuffer

public OutputBuffer getOutputBuffer()

Description copied from interface: NativeDataTarget

Gets the output buffer.

Specified by:

getOutputBuffer in interface NativeDataTarget

loadData

public void loadData()
              throws IOException

Description copied from interface: NativeDataSource

load data from upstream

Specified by:

loadData in interface NativeDataSource

Throws:

IOException

setDataReceiver

public void setDataReceiver(DataReceiver handler)

Description copied from interface: NativeDataSource

set listener. When data from upstream arrives, the listener will be activated.

Specified by:

setDataReceiver in interface NativeDataSource

name

public String name()

Specified by:

name in interface INativeHandler