public class KeyValueInputMerger
extends org.apache.tez.runtime.library.api.KeyValueReader
Modifier and Type | Field and Description |
---|---|
static org.slf4j.Logger |
l4j |
Constructor and Description |
---|
KeyValueInputMerger(List<org.apache.tez.runtime.library.api.KeyValueReader> multiMRInputs,
Deserializer deserializer,
ObjectInspector[] inputObjInspectors,
List<String> sortCols) |
Modifier and Type | Method and Description |
---|---|
Object |
getCurrentKey() |
Object |
getCurrentValue() |
boolean |
next() |
public KeyValueInputMerger(List<org.apache.tez.runtime.library.api.KeyValueReader> multiMRInputs, Deserializer deserializer, ObjectInspector[] inputObjInspectors, List<String> sortCols) throws Exception
Exception
public boolean next() throws IOException
next
in class org.apache.tez.runtime.library.api.KeyValueReader
IOException
public Object getCurrentKey() throws IOException
getCurrentKey
in class org.apache.tez.runtime.library.api.KeyValueReader
IOException
public Object getCurrentValue() throws IOException
getCurrentValue
in class org.apache.tez.runtime.library.api.KeyValueReader
IOException
Copyright © 2016 The Apache Software Foundation. All rights reserved.