public class LlapArrowRowRecordReader extends LlapRowRecordReader
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) |
Modifier and Type | Method and Description |
---|---|
protected AbstractSerDe |
createSerDe() |
boolean |
next(org.apache.hadoop.io.NullWritable key,
Row value) |
close, createKey, createValue, getPos, getProgress, getSchema, initSerDe, setRowFromStruct
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
IOException
public boolean next(org.apache.hadoop.io.NullWritable key, Row value) throws IOException
next
in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,Row>
next
in class LlapRowRecordReader
IOException
protected AbstractSerDe createSerDe() throws SerDeException
createSerDe
in class LlapRowRecordReader
SerDeException
Copyright © 2022 The Apache Software Foundation. All rights reserved.