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 |
---|---|
void |
clean()
Cleanup references
|
Object |
getCurrentKey() |
Object |
getCurrentValue() |
boolean |
next() |
void |
setIOCxt(IOContext ioCxt)
Set the IOContext reference so that input path can be changed.
|
public KeyValueInputMerger(List<org.apache.tez.runtime.library.api.KeyValueReader> multiMRInputs, Deserializer deserializer, ObjectInspector[] inputObjInspectors, List<String> sortCols) throws Exception
Exception
public void setIOCxt(IOContext ioCxt)
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
public void clean()
Copyright © 2022 The Apache Software Foundation. All rights reserved.