org.apache.paimon.utils

Class VectorMappingUtils

java.lang.Object

org.apache.paimon.utils.VectorMappingUtils

public class VectorMappingUtils
extends Object

This is a util about how to expand the ColumnVectors with the partition row and index mapping. For example, we fetch the column of a, b, c from orc file, but the schema of table is a, a1, a2, pt, b, a, b1, c Then we use `createPartitionMappedVectors` to fill to partition pt to a, b, c, the filled columns are a, pt, b, c After this, we use index mapping to expand to a, pt, b, c to a, a1(null), a2(null), pt, b, a, b1(null), c In this way, we don't need ProjectedRow to perform a per-record replace action.

Constructor Summary

Constructors

Constructor and Description
VectorMappingUtils()

Method Summary

Modifier and Type	Method and Description
static ColumnVector	createFixedVector(DataType dataType, BinaryRow partition, int index)
static ColumnVector[]	createIndexMappedVectors(int[] indexMapping, ColumnVector[] vectors)
static ColumnVector[]	createPartitionMappedVectors(PartitionInfo partitionInfo, ColumnVector[] vectors)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

VectorMappingUtils

public VectorMappingUtils()

Method Detail

createPartitionMappedVectors

public static ColumnVector[] createPartitionMappedVectors(PartitionInfo partitionInfo,
                                                          ColumnVector[] vectors)

createFixedVector

public static ColumnVector createFixedVector(DataType dataType,
                                             BinaryRow partition,
                                             int index)

createIndexMappedVectors

public static ColumnVector[] createIndexMappedVectors(int[] indexMapping,
                                                      ColumnVector[] vectors)