public class HiveReduceFunctionResultList<V> extends HiveBaseFunctionResultList<scala.Tuple2<HiveKey,V>>
Constructor and Description |
---|
HiveReduceFunctionResultList(Iterator<scala.Tuple2<HiveKey,V>> inputIterator,
SparkReduceRecordHandler reducer)
Instantiate result set Iterable for Reduce function output.
|
Modifier and Type | Method and Description |
---|---|
protected void |
closeRecordProcessor()
Close the record processor.
|
protected boolean |
processingDone() |
protected void |
processNextRecord(scala.Tuple2<HiveKey,V> inputRecord)
Process the given record.
|
collect, hasNext, next, remove
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
forEachRemaining
public HiveReduceFunctionResultList(Iterator<scala.Tuple2<HiveKey,V>> inputIterator, SparkReduceRecordHandler reducer)
inputIterator
- Input record iterator.reducer
- Initialized ExecReducer
instance.protected void processNextRecord(scala.Tuple2<HiveKey,V> inputRecord) throws IOException
HiveBaseFunctionResultList
processNextRecord
in class HiveBaseFunctionResultList<scala.Tuple2<HiveKey,V>>
IOException
protected boolean processingDone()
processingDone
in class HiveBaseFunctionResultList<scala.Tuple2<HiveKey,V>>
protected void closeRecordProcessor()
HiveBaseFunctionResultList
closeRecordProcessor
in class HiveBaseFunctionResultList<scala.Tuple2<HiveKey,V>>
Copyright © 2022 The Apache Software Foundation. All rights reserved.