org.apache.paimon.data.columnar

Class VectorizedColumnBatch

java.lang.Object

org.apache.paimon.data.columnar.VectorizedColumnBatch

All Implemented Interfaces:

Serializable

public class VectorizedColumnBatch
extends Object
implements Serializable

A VectorizedColumnBatch is a set of rows, organized with each column as a vector. It is the unit of query execution, organized to minimize the cost per row.

VectorizedColumnBatchs are influenced by Apache Hive VectorizedRowBatch.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
ColumnVector[]	columns
static int	DEFAULT_SIZE This number is carefully chosen to minimize overhead and typically allows one VectorizedColumnBatch to fit in cache.

Constructor Summary

Constructors

Constructor and Description
VectorizedColumnBatch(ColumnVector[] vectors)

Method Summary

Modifier and Type	Method and Description
VectorizedColumnBatch	copy(ColumnVector[] vectors)
int	getArity()
InternalArray	getArray(int rowId, int colId)
byte[]	getBinary(int rowId, int pos)
boolean	getBoolean(int rowId, int colId)
byte	getByte(int rowId, int colId)
BytesColumnVector.Bytes	getByteArray(int rowId, int colId)
Decimal	getDecimal(int rowId, int colId, int precision, int scale)
double	getDouble(int rowId, int colId)
float	getFloat(int rowId, int colId)
int	getInt(int rowId, int colId)
long	getLong(int rowId, int colId)
InternalMap	getMap(int rowId, int colId)
int	getNumRows()
InternalRow	getRow(int rowId, int colId)
short	getShort(int rowId, int colId)
BinaryString	getString(int rowId, int pos)
Timestamp	getTimestamp(int rowId, int colId, int precision)
boolean	isNullAt(int rowId, int colId)
void	setNumRows(int numRows)

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_SIZE

public static final int DEFAULT_SIZE

This number is carefully chosen to minimize overhead and typically allows one VectorizedColumnBatch to fit in cache.

See Also:

Constant Field Values

columns

public final ColumnVector[] columns

Constructor Detail

VectorizedColumnBatch

public VectorizedColumnBatch(ColumnVector[] vectors)

Method Detail

setNumRows

public void setNumRows(int numRows)

getNumRows

public int getNumRows()

getArity

public int getArity()

isNullAt

public boolean isNullAt(int rowId,
                        int colId)

getBoolean

public boolean getBoolean(int rowId,
                          int colId)

getByte

public byte getByte(int rowId,
                    int colId)

getShort

public short getShort(int rowId,
                      int colId)

getInt

public int getInt(int rowId,
                  int colId)

getLong

public long getLong(int rowId,
                    int colId)

getFloat

public float getFloat(int rowId,
                      int colId)

getDouble

public double getDouble(int rowId,
                        int colId)

getString

public BinaryString getString(int rowId,
                              int pos)

getBinary

public byte[] getBinary(int rowId,
                        int pos)

getByteArray

public BytesColumnVector.Bytes getByteArray(int rowId,
                                            int colId)

getDecimal

public Decimal getDecimal(int rowId,
                          int colId,
                          int precision,
                          int scale)

getTimestamp

public Timestamp getTimestamp(int rowId,
                              int colId,
                              int precision)

getArray

public InternalArray getArray(int rowId,
                              int colId)

getRow

public InternalRow getRow(int rowId,
                          int colId)

getMap

public InternalMap getMap(int rowId,
                          int colId)

copy

public VectorizedColumnBatch copy(ColumnVector[] vectors)