public abstract class HiveBaseFunctionResultList<T> extends Object implements Iterator, org.apache.hadoop.mapred.OutputCollector<HiveKey,org.apache.hadoop.io.BytesWritable>, Serializable
Constructor and Description |
---|
HiveBaseFunctionResultList(Iterator<T> inputIterator) |
Modifier and Type | Method and Description |
---|---|
protected abstract void |
closeRecordProcessor()
Close the record processor.
|
void |
collect(HiveKey key,
org.apache.hadoop.io.BytesWritable value) |
boolean |
hasNext() |
scala.Tuple2<HiveKey,org.apache.hadoop.io.BytesWritable> |
next() |
protected abstract boolean |
processingDone() |
protected abstract void |
processNextRecord(T inputRecord)
Process the given record.
|
void |
remove() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
forEachRemaining
public void collect(HiveKey key, org.apache.hadoop.io.BytesWritable value) throws IOException
collect
in interface org.apache.hadoop.mapred.OutputCollector<HiveKey,org.apache.hadoop.io.BytesWritable>
IOException
protected abstract void processNextRecord(T inputRecord) throws IOException
IOException
protected abstract boolean processingDone()
protected abstract void closeRecordProcessor()
public scala.Tuple2<HiveKey,org.apache.hadoop.io.BytesWritable> next()
Copyright © 2022 The Apache Software Foundation. All rights reserved.