Package 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

@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	Description
static final int	KV_HEADER_LENGTH

Constructor Summary

Constructors

Constructor	Description
BufferPuller(NativeDataSource handler)

Method Summary

Modifier and Type	Method	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 Details

KV_HEADER_LENGTH

public static final int KV_HEADER_LENGTH

See Also:

• Constant Field Values

Constructor Details

BufferPuller

public BufferPuller(NativeDataSource handler)
             throws IOException

Throws:

IOException

Method Details

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