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

Class KeyValuesFromKeyValue

java.lang.Object

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

All Implemented Interfaces:

KeyValuesAdapter

public class KeyValuesFromKeyValue
extends Object
implements KeyValuesAdapter

Provides a key/values (note the plural values) interface out of a KeyValueReader, needed by ReduceRecordSource when reading input from a key/value source.

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.tez.runtime.library.api.KeyValueReader	reader
protected org.apache.hadoop.hive.ql.exec.tez.KeyValuesFromKeyValue.ValueIterator<Object>	valueIterator

Constructor Summary

Constructors

Constructor and Description
KeyValuesFromKeyValue(org.apache.tez.runtime.library.api.KeyValueReader 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.KeyValueReader reader

valueIterator

protected org.apache.hadoop.hive.ql.exec.tez.KeyValuesFromKeyValue.ValueIterator<Object> valueIterator

Constructor Detail

KeyValuesFromKeyValue

public KeyValuesFromKeyValue(org.apache.tez.runtime.library.api.KeyValueReader 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