org.apache.hadoop.hive.ql.exec.tez

Class KeyValuesFromKeyValues

java.lang.Object

org.apache.hadoop.hive.ql.exec.tez.KeyValuesFromKeyValues

All Implemented Interfaces:

KeyValuesAdapter

public class KeyValuesFromKeyValues
extends Object
implements KeyValuesAdapter

Provides a key/values interface out of a KeyValuesReader for use by ReduceRecordSource.

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.tez.runtime.library.api.KeyValuesReader	reader

Constructor Summary

Constructors

Constructor and Description
KeyValuesFromKeyValues(org.apache.tez.runtime.library.api.KeyValuesReader reader)

Method Summary

Modifier and Type	Method and Description
Object	getCurrentKey() Get the key for current record
Iterable<Object>	getCurrentValues() Get the values for the current record
boolean	next() Move to the next record

Methods inherited from class java.lang.Object

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

Field Detail

reader

protected org.apache.tez.runtime.library.api.KeyValuesReader reader

Constructor Detail

KeyValuesFromKeyValues

public KeyValuesFromKeyValues(org.apache.tez.runtime.library.api.KeyValuesReader reader)

Method Detail

getCurrentKey

public Object getCurrentKey()
                     throws IOException

Description copied from interface: KeyValuesAdapter

Get the key for current record

Specified by:

getCurrentKey in interface KeyValuesAdapter

Returns:

Throws:

IOException

getCurrentValues

public Iterable<Object> getCurrentValues()
                                  throws IOException

Description copied from interface: KeyValuesAdapter

Get the values for the current record

Specified by:

getCurrentValues in interface KeyValuesAdapter

Returns:

Throws:

IOException

next

public boolean next()
             throws IOException

Description copied from interface: KeyValuesAdapter

Move to the next record

Specified by:

next in interface KeyValuesAdapter

Returns:

true if successful, false if there are no more records to process

Throws:

IOException