public class VectorizedRowBatchCtx extends Object
Constructor and Description |
---|
VectorizedRowBatchCtx()
Constructor for VectorizedRowBatchCtx
|
VectorizedRowBatchCtx(String[] rowColumnNames,
TypeInfo[] rowColumnTypeInfos,
int[] dataColumnNums,
int partitionColumnCount,
String[] scratchColumnTypeNames) |
Modifier and Type | Method and Description |
---|---|
void |
addPartitionColsToBatch(org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch batch,
Object[] partitionValues)
Add the partition values to the batch
|
org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch |
createVectorizedRowBatch()
Creates a Vectorized row batch and the column vectors.
|
int |
getDataColumnCount() |
int[] |
getDataColumnNums() |
int |
getPartitionColumnCount() |
static void |
getPartitionValues(VectorizedRowBatchCtx vrbCtx,
org.apache.hadoop.conf.Configuration hiveConf,
org.apache.hadoop.mapred.FileSplit split,
Object[] partitionValues) |
static void |
getPartitionValues(VectorizedRowBatchCtx vrbCtx,
MapWork mapWork,
org.apache.hadoop.mapred.FileSplit split,
Object[] partitionValues) |
static void |
getPartitionValues(VectorizedRowBatchCtx vrbCtx,
PartitionDesc partDesc,
Object[] partitionValues) |
String[] |
getRowColumnNames() |
TypeInfo[] |
getRowColumnTypeInfos() |
String[] |
getScratchColumnTypeNames() |
void |
init(StructObjectInspector structObjectInspector,
String[] scratchColumnTypeNames)
Initializes the VectorizedRowBatch context based on an scratch column type names and
object inspector.
|
boolean |
isPartitionCol(int colNum)
Determine whether a given column is a partition column
|
public VectorizedRowBatchCtx()
public String[] getRowColumnNames()
public TypeInfo[] getRowColumnTypeInfos()
public int[] getDataColumnNums()
public int getDataColumnCount()
public int getPartitionColumnCount()
public String[] getScratchColumnTypeNames()
public void init(StructObjectInspector structObjectInspector, String[] scratchColumnTypeNames) throws HiveException
structObjectInspector
- scratchColumnTypeNames
- Object inspector that shapes the column typesHiveException
public static void getPartitionValues(VectorizedRowBatchCtx vrbCtx, org.apache.hadoop.conf.Configuration hiveConf, org.apache.hadoop.mapred.FileSplit split, Object[] partitionValues) throws IOException
IOException
public static void getPartitionValues(VectorizedRowBatchCtx vrbCtx, MapWork mapWork, org.apache.hadoop.mapred.FileSplit split, Object[] partitionValues) throws IOException
IOException
public static void getPartitionValues(VectorizedRowBatchCtx vrbCtx, PartitionDesc partDesc, Object[] partitionValues)
public org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch createVectorizedRowBatch()
HiveException
public void addPartitionColsToBatch(org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch batch, Object[] partitionValues)
batch
- partitionValues
- HiveException
public final boolean isPartitionCol(int colNum)
colNum
- column number in
VectorizedRowBatch
s created by this context.Copyright © 2021 The Apache Software Foundation. All rights reserved.