org.apache.hadoop.mapred

Class CollectiveMapper.KeyValReader

java.lang.Object

org.apache.hadoop.mapred.CollectiveMapper.KeyValReader

Enclosing class:

CollectiveMapper<KEYIN,VALUEIN,KEYOUT,VALUEOUT>

protected class CollectiveMapper.KeyValReader
extends java.lang.Object

A Key-Value reader to read key-value inputs for this worker.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	KeyValReader(Context context)

Method Summary

Modifier and Type	Method and Description
KEYIN	getCurrentKey() Get the current key
VALUEIN	getCurrentValue() Get the current value
boolean	nextKeyValue() Get the next key-value

Methods inherited from class java.lang.Object

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

Constructor Detail

KeyValReader

protected KeyValReader(Context context)

Method Detail

nextKeyValue

public boolean nextKeyValue()
                     throws java.io.IOException,
                            java.lang.InterruptedException

Get the next key-value

Returns:

the next key-value

Throws:

java.io.IOException

java.lang.InterruptedException

getCurrentKey

public KEYIN getCurrentKey()
                    throws java.io.IOException,
                           java.lang.InterruptedException

Get the current key

Returns:

the current key

Throws:

java.io.IOException

java.lang.InterruptedException

getCurrentValue

public VALUEIN getCurrentValue()
                        throws java.io.IOException,
                               java.lang.InterruptedException

Get the current value

Returns:

the current value

Throws:

java.io.IOException

java.lang.InterruptedException