org.apache.hadoop.mapred.nativetask

Interface NativeDataSource

All Known Subinterfaces:

INativeHandler

All Known Implementing Classes:

NativeBatchProcessor

@InterfaceAudience.Private
public interface NativeDataSource

NativeDataSource loads data from upstream

Method Summary

Modifier and Type	Method and Description
InputBuffer	getInputBuffer() get input buffer
void	loadData() load data from upstream
void	setDataReceiver(DataReceiver handler) set listener.

Method Detail

getInputBuffer

InputBuffer getInputBuffer()

get input buffer

setDataReceiver

void setDataReceiver(DataReceiver handler)

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

loadData

void loadData()
       throws IOException

load data from upstream

Throws:

IOException