Modifier and Type | Field and Description |
---|---|
protected org.apache.hadoop.conf.Configuration |
conf |
protected org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.Text> |
reader |
protected Schema |
schema |
protected AbstractSerDe |
serde |
protected org.apache.hadoop.io.Text |
textData |
Constructor and Description |
---|
LlapRowRecordReader(org.apache.hadoop.conf.Configuration conf,
Schema schema,
org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.Text> reader) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
org.apache.hadoop.io.NullWritable |
createKey() |
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 final org.apache.hadoop.conf.Configuration conf
protected final org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.Text> reader
protected final Schema schema
protected final AbstractSerDe serde
protected final org.apache.hadoop.io.Text textData
public LlapRowRecordReader(org.apache.hadoop.conf.Configuration conf, Schema schema, org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.Text> reader) throws IOException
IOException
public void close() throws IOException
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 AbstractSerDe initSerDe(org.apache.hadoop.conf.Configuration conf) throws SerDeException
SerDeException
Copyright © 2021 The Apache Software Foundation. All rights reserved.