org.apache.hadoop.hive.llap

Class LlapRowRecordReader

java.lang.Object

org.apache.hadoop.hive.llap.LlapRowRecordReader

All Implemented Interfaces:

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

Direct Known Subclasses:

LlapArrowRowRecordReader

public class LlapRowRecordReader
extends Object
implements org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,Row>

Row-based record reader for LLAP.

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.hadoop.conf.Configuration	conf
protected org.apache.hadoop.io.Writable	data
protected org.apache.hadoop.mapred.RecordReader	reader
protected Schema	schema
protected AbstractSerDe	serde

Constructor Summary

Constructors

Constructor and Description
LlapRowRecordReader(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
void	close()
org.apache.hadoop.io.NullWritable	createKey()
protected AbstractSerDe	createSerDe()
Row	createValue()
long	getPos()
float	getProgress()
Schema	getSchema()
protected AbstractSerDe	initSerDe(org.apache.hadoop.conf.Configuration conf)
boolean	next(org.apache.hadoop.io.NullWritable key, Row value)
protected static void	setRowFromStruct(Row row, Object structVal, StructObjectInspector soi)

Methods inherited from class java.lang.Object

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

Field Detail

conf

protected final org.apache.hadoop.conf.Configuration conf

reader

protected final org.apache.hadoop.mapred.RecordReader reader

schema

protected final Schema schema

serde

protected final AbstractSerDe serde

data

protected final org.apache.hadoop.io.Writable data

Constructor Detail

LlapRowRecordReader

public LlapRowRecordReader(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

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,Row>

Throws:

IOException

createKey

public org.apache.hadoop.io.NullWritable createKey()

Specified by:

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

createValue

public Row createValue()

Specified by:

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

getPos

public long getPos()
            throws IOException

Specified by:

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

Throws:

IOException

getProgress

public float getProgress()
                  throws IOException

Specified by:

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

Throws:

IOException

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>

Throws:

IOException

getSchema

public Schema getSchema()

setRowFromStruct

protected static void setRowFromStruct(Row row,
                                       Object structVal,
                                       StructObjectInspector soi)

createSerDe

protected AbstractSerDe createSerDe()
                             throws SerDeException

Throws:

SerDeException

initSerDe

protected AbstractSerDe initSerDe(org.apache.hadoop.conf.Configuration conf)
                           throws SerDeException

Throws:

SerDeException