org.apache.hadoop.mapred.nativetask.handlers

Class BufferPuller

java.lang.Object

org.apache.hadoop.mapred.nativetask.handlers.BufferPuller

All Implemented Interfaces:

DataReceiver, org.apache.hadoop.mapred.RawKeyValueIterator

@InterfaceAudience.Private
public class BufferPuller
extends Object
implements org.apache.hadoop.mapred.RawKeyValueIterator, DataReceiver

actively signal a BufferPullee to load data into buffer and receive

Field Summary

Fields

Modifier and Type	Field and Description
static int	KV_HEADER_LENGTH

Constructor Summary

Constructors

Constructor and Description
BufferPuller(NativeDataSource handler)

Method Summary

Modifier and Type	Method and Description
void	close() Closes the iterator so that the underlying streams can be closed.
org.apache.hadoop.io.DataInputBuffer	getKey()
org.apache.hadoop.util.Progress	getProgress()
org.apache.hadoop.io.DataInputBuffer	getValue()
boolean	next()
boolean	receiveData() Send a signal to the receiver that the data arrives.
void	reset()

Methods inherited from class java.lang.Object

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

Field Detail

KV_HEADER_LENGTH

public static final int KV_HEADER_LENGTH

See Also:

Constant Field Values

Constructor Detail

BufferPuller

public BufferPuller(NativeDataSource handler)
             throws IOException

Throws:

IOException

Method Detail

getKey

public org.apache.hadoop.io.DataInputBuffer getKey()
                                            throws IOException

Specified by:

getKey in interface org.apache.hadoop.mapred.RawKeyValueIterator

Throws:

IOException

getValue

public org.apache.hadoop.io.DataInputBuffer getValue()
                                              throws IOException

Specified by:

getValue in interface org.apache.hadoop.mapred.RawKeyValueIterator

Throws:

IOException

reset

public void reset()

next

public boolean next()
             throws IOException

Specified by:

next in interface org.apache.hadoop.mapred.RawKeyValueIterator

Throws:

IOException

receiveData

public boolean receiveData()
                    throws IOException

Description copied from interface: DataReceiver

Send a signal to the receiver that the data arrives. The data is transferred in another band.

Specified by:

receiveData in interface DataReceiver

Throws:

IOException

getProgress

public org.apache.hadoop.util.Progress getProgress()

Specified by:

getProgress in interface org.apache.hadoop.mapred.RawKeyValueIterator

close

public void close()
           throws IOException

Closes the iterator so that the underlying streams can be closed.

Specified by:

close in interface org.apache.hadoop.mapred.RawKeyValueIterator

Throws:

IOException