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

Class KeyValueInputMerger

java.lang.Object

org.apache.tez.runtime.api.Reader

org.apache.tez.runtime.library.api.KeyValueReader

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

public class KeyValueInputMerger
extends org.apache.tez.runtime.library.api.KeyValueReader

A KeyValuesReader implementation that returns a sorted stream of key-values by doing a sorted merge of the key-value in LogicalInputs. Tags are in the last byte of the key, so no special handling for tags is required. Uses a priority queue to pick the KeyValuesReader of the input that is next in sort order.

Field Summary

Fields

Modifier and Type	Field and Description
static org.apache.commons.logging.Log	l4j

Constructor Summary

Constructors

Constructor and Description
KeyValueInputMerger(List<org.apache.tez.runtime.library.api.KeyValueReader> multiMRInputs, Deserializer deserializer, ObjectInspector[] inputObjInspectors, List<String> sortCols)

Method Summary

Methods

Modifier and Type	Method and Description
Object	getCurrentKey()
Object	getCurrentValue()
boolean	next()

Methods inherited from class java.lang.Object

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

Field Detail

l4j

public static final org.apache.commons.logging.Log l4j

Constructor Detail

KeyValueInputMerger

public KeyValueInputMerger(List<org.apache.tez.runtime.library.api.KeyValueReader> multiMRInputs,
                   Deserializer deserializer,
                   ObjectInspector[] inputObjInspectors,
                   List<String> sortCols)
                    throws Exception

Throws:

Exception

Method Detail

next

public boolean next()
             throws IOException

Specified by:

next in class org.apache.tez.runtime.library.api.KeyValueReader

Returns:

true if there are more key-values and advances to next key-values

Throws:

IOException

getCurrentKey

public Object getCurrentKey()
                     throws IOException

Specified by:

getCurrentKey in class org.apache.tez.runtime.library.api.KeyValueReader

Throws:

IOException

getCurrentValue

public Object getCurrentValue()
                       throws IOException

Specified by:

getCurrentValue in class org.apache.tez.runtime.library.api.KeyValueReader

Throws:

IOException