public class HiveMapFunctionResultList extends HiveBaseFunctionResultList<scala.Tuple2<org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.BytesWritable>>
HiveBaseFunctionResultList.ResultIterator
Constructor and Description |
---|
HiveMapFunctionResultList(Iterator<scala.Tuple2<org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.BytesWritable>> inputIterator,
SparkRecordHandler handler)
Instantiate result set Iterable for Map function output.
|
Modifier and Type | Method and Description |
---|---|
protected void |
closeRecordProcessor()
Close the record processor.
|
protected boolean |
processingDone() |
protected void |
processNextRecord(scala.Tuple2<org.apache.hadoop.io.BytesWritable,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 HiveMapFunctionResultList(Iterator<scala.Tuple2<org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.BytesWritable>> inputIterator, SparkRecordHandler handler)
inputIterator
- Input record iterator.handler
- Initialized SparkMapRecordHandler
instance.protected void processNextRecord(scala.Tuple2<org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.BytesWritable> inputRecord) throws IOException
HiveBaseFunctionResultList
processNextRecord
in class HiveBaseFunctionResultList<scala.Tuple2<org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.BytesWritable>>
IOException
protected boolean processingDone()
processingDone
in class HiveBaseFunctionResultList<scala.Tuple2<org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.BytesWritable>>
protected void closeRecordProcessor()
HiveBaseFunctionResultList
closeRecordProcessor
in class HiveBaseFunctionResultList<scala.Tuple2<org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.BytesWritable>>
Copyright © 2016 The Apache Software Foundation. All rights reserved.