org.apache.hadoop.hive.llap

Class LlapArrowBatchRecordReader

java.lang.Object

org.apache.hadoop.hive.llap.LlapBaseRecordReader<ArrowWrapperWritable>

org.apache.hadoop.hive.llap.LlapArrowBatchRecordReader

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,ArrowWrapperWritable>

public class LlapArrowBatchRecordReader
extends LlapBaseRecordReader<ArrowWrapperWritable>

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hive.llap.LlapBaseRecordReader

LlapBaseRecordReader.ReaderEvent

Field Summary

Fields inherited from class org.apache.hadoop.hive.llap.LlapBaseRecordReader

cin, clazz, client, din, readerEvents, readerThread, schema

Constructor Summary

Constructors

Constructor and Description
LlapArrowBatchRecordReader(InputStream in, Schema schema, Class<ArrowWrapperWritable> clazz, org.apache.hadoop.mapred.JobConf job, Closeable client, Socket socket, long arrowAllocatorLimit)

Method Summary

Modifier and Type	Method and Description
void	close()
boolean	next(org.apache.hadoop.io.NullWritable key, ArrowWrapperWritable value)

Methods inherited from class org.apache.hadoop.hive.llap.LlapBaseRecordReader

createKey, createValue, failOnInterruption, getPos, getProgress, getReaderEvent, getReaderThread, getSchema, handleEvent, hasInput, processReaderEvent, setReaderThread

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

LlapArrowBatchRecordReader

public LlapArrowBatchRecordReader(InputStream in,
                                  Schema schema,
                                  Class<ArrowWrapperWritable> clazz,
                                  org.apache.hadoop.mapred.JobConf job,
                                  Closeable client,
                                  Socket socket,
                                  long arrowAllocatorLimit)
                           throws IOException

Throws:

IOException

Method Detail

next

public boolean next(org.apache.hadoop.io.NullWritable key,
                    ArrowWrapperWritable value)
             throws IOException

Specified by:

next in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,ArrowWrapperWritable>

Overrides:

next in class LlapBaseRecordReader<ArrowWrapperWritable>

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Specified by:

close in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,ArrowWrapperWritable>

Overrides:

close in class LlapBaseRecordReader<ArrowWrapperWritable>

Throws:

IOException