public abstract class BatchToRowReader<StructType,UnionType> extends Object implements org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,Object>
Modifier and Type | Field and Description |
---|---|
protected static org.slf4j.Logger |
LOG |
Constructor and Description |
---|
BatchToRowReader(org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch> vrbReader,
VectorizedRowBatchCtx vrbCtx,
List<Integer> includedCols) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
org.apache.hadoop.io.NullWritable |
createKey() |
protected abstract StructType |
createStructObject(Object previous,
List<TypeInfo> childrenTypes) |
protected abstract UnionType |
createUnionObject(List<TypeInfo> childrenTypes,
Object previous) |
Object |
createValue() |
long |
getPos() |
float |
getProgress() |
protected abstract Object |
getStructCol(StructType structObj,
int i) |
protected abstract Object |
getUnionField(UnionType unionObj) |
boolean |
next(org.apache.hadoop.io.NullWritable key,
Object previous) |
static org.apache.hadoop.io.BytesWritable |
nextBinary(org.apache.hadoop.hive.ql.exec.vector.ColumnVector vector,
int row,
Object previous) |
static org.apache.hadoop.io.BooleanWritable |
nextBoolean(org.apache.hadoop.hive.ql.exec.vector.ColumnVector vector,
int row,
Object previous) |
static ByteWritable |
nextByte(org.apache.hadoop.hive.ql.exec.vector.ColumnVector vector,
int row,
Object previous) |
static HiveCharWritable |
nextChar(org.apache.hadoop.hive.ql.exec.vector.ColumnVector vector,
int row,
int size,
Object previous) |
static DateWritableV2 |
nextDate(org.apache.hadoop.hive.ql.exec.vector.ColumnVector vector,
int row,
Object previous) |
static org.apache.hadoop.hive.serde2.io.HiveDecimalWritable |
nextDecimal(org.apache.hadoop.hive.ql.exec.vector.ColumnVector vector,
int row,
Object previous) |
static DoubleWritable |
nextDouble(org.apache.hadoop.hive.ql.exec.vector.ColumnVector vector,
int row,
Object previous) |
static org.apache.hadoop.io.FloatWritable |
nextFloat(org.apache.hadoop.hive.ql.exec.vector.ColumnVector vector,
int row,
Object previous) |
static org.apache.hadoop.io.IntWritable |
nextInt(org.apache.hadoop.hive.ql.exec.vector.ColumnVector vector,
int row,
Object previous) |
static org.apache.hadoop.io.LongWritable |
nextLong(org.apache.hadoop.hive.ql.exec.vector.ColumnVector vector,
int row,
Object previous) |
static ShortWritable |
nextShort(org.apache.hadoop.hive.ql.exec.vector.ColumnVector vector,
int row,
Object previous) |
static org.apache.hadoop.io.Text |
nextString(org.apache.hadoop.hive.ql.exec.vector.ColumnVector vector,
int row,
Object previous) |
StructType |
nextStruct(org.apache.hadoop.hive.ql.exec.vector.ColumnVector vector,
int row,
StructTypeInfo schema,
Object previous) |
static TimestampWritableV2 |
nextTimestamp(org.apache.hadoop.hive.ql.exec.vector.ColumnVector vector,
int row,
Object previous) |
static HiveVarcharWritable |
nextVarchar(org.apache.hadoop.hive.ql.exec.vector.ColumnVector vector,
int row,
int size,
Object previous) |
protected abstract void |
setStructCol(StructType structObj,
int i,
Object value) |
protected abstract void |
setUnion(UnionType unionObj,
byte tag,
Object object) |
public BatchToRowReader(org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch> vrbReader, VectorizedRowBatchCtx vrbCtx, List<Integer> includedCols)
protected abstract StructType createStructObject(Object previous, List<TypeInfo> childrenTypes)
protected abstract void setStructCol(StructType structObj, int i, Object value)
protected abstract Object getStructCol(StructType structObj, int i)
protected abstract UnionType createUnionObject(List<TypeInfo> childrenTypes, Object previous)
public org.apache.hadoop.io.NullWritable createKey()
createKey
in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,Object>
public Object createValue()
createValue
in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,Object>
public long getPos() throws IOException
getPos
in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,Object>
IOException
public float getProgress() throws IOException
getProgress
in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,Object>
IOException
public boolean next(org.apache.hadoop.io.NullWritable key, Object previous) throws IOException
next
in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,Object>
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,Object>
IOException
public static org.apache.hadoop.io.BooleanWritable nextBoolean(org.apache.hadoop.hive.ql.exec.vector.ColumnVector vector, int row, Object previous)
public static ByteWritable nextByte(org.apache.hadoop.hive.ql.exec.vector.ColumnVector vector, int row, Object previous)
public static ShortWritable nextShort(org.apache.hadoop.hive.ql.exec.vector.ColumnVector vector, int row, Object previous)
public static org.apache.hadoop.io.IntWritable nextInt(org.apache.hadoop.hive.ql.exec.vector.ColumnVector vector, int row, Object previous)
public static org.apache.hadoop.io.LongWritable nextLong(org.apache.hadoop.hive.ql.exec.vector.ColumnVector vector, int row, Object previous)
public static org.apache.hadoop.io.FloatWritable nextFloat(org.apache.hadoop.hive.ql.exec.vector.ColumnVector vector, int row, Object previous)
public static DoubleWritable nextDouble(org.apache.hadoop.hive.ql.exec.vector.ColumnVector vector, int row, Object previous)
public static org.apache.hadoop.io.Text nextString(org.apache.hadoop.hive.ql.exec.vector.ColumnVector vector, int row, Object previous)
public static HiveCharWritable nextChar(org.apache.hadoop.hive.ql.exec.vector.ColumnVector vector, int row, int size, Object previous)
public static HiveVarcharWritable nextVarchar(org.apache.hadoop.hive.ql.exec.vector.ColumnVector vector, int row, int size, Object previous)
public static org.apache.hadoop.io.BytesWritable nextBinary(org.apache.hadoop.hive.ql.exec.vector.ColumnVector vector, int row, Object previous)
public static org.apache.hadoop.hive.serde2.io.HiveDecimalWritable nextDecimal(org.apache.hadoop.hive.ql.exec.vector.ColumnVector vector, int row, Object previous)
public static DateWritableV2 nextDate(org.apache.hadoop.hive.ql.exec.vector.ColumnVector vector, int row, Object previous)
public static TimestampWritableV2 nextTimestamp(org.apache.hadoop.hive.ql.exec.vector.ColumnVector vector, int row, Object previous)
public StructType nextStruct(org.apache.hadoop.hive.ql.exec.vector.ColumnVector vector, int row, StructTypeInfo schema, Object previous)
Copyright © 2022 The Apache Software Foundation. All rights reserved.