public class LlapRowRecordReader extends Object implements org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,Row>
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 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) |
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) |
protected final org.apache.hadoop.conf.Configuration conf
protected final org.apache.hadoop.mapred.RecordReader reader
protected final Schema schema
protected final AbstractSerDe serde
protected final org.apache.hadoop.io.Writable data
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
IOException
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
close
in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,Row>
IOException
public org.apache.hadoop.io.NullWritable createKey()
createKey
in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,Row>
public Row createValue()
createValue
in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,Row>
public long getPos() throws IOException
getPos
in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,Row>
IOException
public float getProgress() throws IOException
getProgress
in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,Row>
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>
IOException
public Schema getSchema()
protected static void setRowFromStruct(Row row, Object structVal, StructObjectInspector soi)
protected AbstractSerDe createSerDe() throws SerDeException
SerDeException
protected AbstractSerDe initSerDe(org.apache.hadoop.conf.Configuration conf) throws SerDeException
SerDeException
Copyright © 2022 The Apache Software Foundation. All rights reserved.