public class VectorizedRowBatchCtx extends Object
Constructor and Description |
---|
VectorizedRowBatchCtx()
Constructor for VectorizedRowBatchCtx
|
VectorizedRowBatchCtx(String[] rowColumnNames,
TypeInfo[] rowColumnTypeInfos,
int partitionColumnCount,
String[] scratchColumnTypeNames) |
Modifier and Type | Method and Description |
---|---|
void |
addPartitionColsToBatch(VectorizedRowBatch batch,
Object[] partitionValues)
Add the partition values to the batch
|
VectorizedRowBatch |
createVectorizedRowBatch()
Creates a Vectorized row batch and the column vectors.
|
VectorizedRowBatch |
createVectorizedRowBatch(boolean[] columnsToIncludeTruncated) |
boolean[] |
getColumnsToIncludeTruncated(org.apache.hadoop.conf.Configuration conf) |
int |
getDataColumnCount() |
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,
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 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, PartitionDesc partDesc, Object[] partitionValues)
public VectorizedRowBatch createVectorizedRowBatch()
HiveException
public VectorizedRowBatch createVectorizedRowBatch(boolean[] columnsToIncludeTruncated)
public boolean[] getColumnsToIncludeTruncated(org.apache.hadoop.conf.Configuration conf)
public void addPartitionColsToBatch(VectorizedRowBatch batch, Object[] partitionValues)
batch
- partitionValues
- HiveException
public final boolean isPartitionCol(int colNum)
colNum
- column number in
VectorizedRowBatch
s created by this context.Copyright © 2016 The Apache Software Foundation. All rights reserved.