org.apache.flink.table.data.columnar.vector

Class VectorizedColumnBatch

java.lang.Object

org.apache.flink.table.data.columnar.vector.VectorizedColumnBatch

All Implemented Interfaces:

Serializable

@Internal
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
int	getArity()
ArrayData	getArray(int rowId, int colId)
boolean	getBoolean(int rowId, int colId)
byte	getByte(int rowId, int colId)
BytesColumnVector.Bytes	getByteArray(int rowId, int colId)
DecimalData	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)
MapData	getMap(int rowId, int colId)
int	getNumRows()
RowData	getRow(int rowId, int colId)
short	getShort(int rowId, int colId)
String	getString(int rowId, int colId)
TimestampData	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)

getByteArray

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

getString

public String getString(int rowId,
                        int colId)

getDecimal

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

getTimestamp

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

getArray

public ArrayData getArray(int rowId,
                          int colId)

getRow

public RowData getRow(int rowId,
                      int colId)

getMap

public MapData getMap(int rowId,
                      int colId)