public class HiveReduceFunctionResultList extends HiveBaseFunctionResultList<scala.Tuple2<HiveKey,Iterable<org.apache.hadoop.io.BytesWritable>>>
HiveBaseFunctionResultList.ResultIterator
Constructor and Description |
---|
HiveReduceFunctionResultList(Iterator<scala.Tuple2<HiveKey,Iterable<org.apache.hadoop.io.BytesWritable>>> 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,Iterable<org.apache.hadoop.io.BytesWritable>> inputRecord)
Process the given record.
|
collect, iterator
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
forEach, spliterator
public HiveReduceFunctionResultList(Iterator<scala.Tuple2<HiveKey,Iterable<org.apache.hadoop.io.BytesWritable>>> inputIterator, SparkReduceRecordHandler reducer)
inputIterator
- Input record iterator.reducer
- Initialized ExecReducer
instance.protected void processNextRecord(scala.Tuple2<HiveKey,Iterable<org.apache.hadoop.io.BytesWritable>> inputRecord) throws IOException
HiveBaseFunctionResultList
processNextRecord
in class HiveBaseFunctionResultList<scala.Tuple2<HiveKey,Iterable<org.apache.hadoop.io.BytesWritable>>>
IOException
protected boolean processingDone()
processingDone
in class HiveBaseFunctionResultList<scala.Tuple2<HiveKey,Iterable<org.apache.hadoop.io.BytesWritable>>>
protected void closeRecordProcessor()
HiveBaseFunctionResultList
closeRecordProcessor
in class HiveBaseFunctionResultList<scala.Tuple2<HiveKey,Iterable<org.apache.hadoop.io.BytesWritable>>>
Copyright © 2017 The Apache Software Foundation. All rights reserved.