org.apache.hadoop.hive.llap

Class LlapArrowRowRecordReader

java.lang.Object

org.apache.hadoop.hive.llap.LlapRowRecordReader

org.apache.hadoop.hive.llap.LlapArrowRowRecordReader

All Implemented Interfaces:

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

public class LlapArrowRowRecordReader
extends LlapRowRecordReader

Buffers a batch for reading one row at a time.

Field Summary

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

conf, data, reader, schema, serde

Constructor Summary

Constructors

Constructor and Description
LlapArrowRowRecordReader(org.apache.hadoop.conf.Configuration conf, Schema schema, org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,? extends org.apache.hadoop.io.Writable> reader)

Method Summary

Modifier and Type	Method and Description
protected AbstractSerDe	createSerDe()
boolean	next(org.apache.hadoop.io.NullWritable key, Row value)

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

close, createKey, createValue, getPos, getProgress, getSchema, initSerDe, setRowFromStruct

Methods inherited from class java.lang.Object

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

Constructor Detail

LlapArrowRowRecordReader

public LlapArrowRowRecordReader(org.apache.hadoop.conf.Configuration conf,
                                Schema schema,
                                org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,? extends org.apache.hadoop.io.Writable> reader)
                         throws IOException

Throws:

IOException

Method Detail

next

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

Specified by:

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

Overrides:

next in class LlapRowRecordReader

Throws:

IOException

createSerDe

protected AbstractSerDe createSerDe()
                             throws SerDeException

Overrides:

createSerDe in class LlapRowRecordReader

Throws:

SerDeException