public class VectorizedOrcAcidRowBatchReader extends Object implements org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch>
Constructor and Description |
---|
VectorizedOrcAcidRowBatchReader(org.apache.hadoop.mapred.InputSplit inputSplit,
org.apache.hadoop.mapred.JobConf conf,
org.apache.hadoop.mapred.Reporter reporter) |
Modifier and Type | Method and Description |
---|---|
static boolean |
canCreateVectorizedAcidRowBatchReaderOnSplit(org.apache.hadoop.mapred.JobConf conf,
org.apache.hadoop.mapred.InputSplit inputSplit)
Returns whether it is possible to create a valid instance of this class for a given split.
|
void |
close() |
org.apache.hadoop.io.NullWritable |
createKey() |
org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch |
createValue() |
long |
getPos() |
float |
getProgress() |
boolean |
next(org.apache.hadoop.io.NullWritable key,
org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch value) |
public VectorizedOrcAcidRowBatchReader(org.apache.hadoop.mapred.InputSplit inputSplit, org.apache.hadoop.mapred.JobConf conf, org.apache.hadoop.mapred.Reporter reporter) throws IOException
IOException
public static boolean canCreateVectorizedAcidRowBatchReaderOnSplit(org.apache.hadoop.mapred.JobConf conf, org.apache.hadoop.mapred.InputSplit inputSplit)
conf
- is the job configurationinputSplit
- public boolean next(org.apache.hadoop.io.NullWritable key, org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch value) throws IOException
next
in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch>
IOException
public org.apache.hadoop.io.NullWritable createKey()
createKey
in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch>
public org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch createValue()
createValue
in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch>
public long getPos() throws IOException
getPos
in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch>
IOException
public void close() throws IOException
close
in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch>
IOException
public float getProgress() throws IOException
getProgress
in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch>
IOException
Copyright © 2021 The Apache Software Foundation. All rights reserved.