org.apache.paimon.format.parquet.reader

Class ParquetDecimalVector

java.lang.Object

org.apache.paimon.format.parquet.reader.ParquetDecimalVector

All Implemented Interfaces:

BytesColumnVector, ColumnVector, DecimalColumnVector, IntColumnVector, LongColumnVector, WritableBytesVector, WritableColumnVector, WritableIntVector, WritableLongVector

public class ParquetDecimalVector
extends Object
implements DecimalColumnVector, WritableLongVector, WritableIntVector, WritableBytesVector

Parquet write decimal as int32 and int64 and binary, this class wrap the real vector to provide DecimalColumnVector interface.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.paimon.data.columnar.BytesColumnVector

BytesColumnVector.Bytes

Constructor Summary

Constructors

Constructor and Description
ParquetDecimalVector(ColumnVector vector)

Method Summary

Modifier and Type	Method and Description
void	appendBytes(int rowId, byte[] value, int offset, int length) Append byte[] at rowId with the provided value.
void	fill(byte[] value) Fill the column vector with the provided value.
void	fill(int value) Fill the column vector with the provided value.
void	fill(long value) Fill the column vector with the provided value.
void	fillWithNulls() Fill the column vector with nulls.
BytesColumnVector.Bytes	getBytes(int i)
Decimal	getDecimal(int i, int precision, int scale)
WritableIntVector	getDictionaryIds() Get reserved dictionary ids.
int	getInt(int i)
long	getLong(int i)
ColumnVector	getVector()
boolean	hasDictionary() Check if there's a dictionary.
boolean	isNullAt(int i)
WritableIntVector	reserveDictionaryIds(int capacity) Reserve a integer column for ids of dictionary.
void	reset() Resets the column to default state.
void	setDictionary(Dictionary dictionary) Set the dictionary, it should work with dictionary ids.
void	setInt(int rowId, int value) Set int at rowId with the provided value.
void	setInts(int rowId, int count, int value) Sets value to [rowId, rowId + count) by the value, this is data that repeats continuously.
void	setInts(int rowId, int count, int[] src, int srcIndex) Sets values from [src[srcIndex], src[srcIndex + count]) to [rowId, rowId + count).
void	setIntsFromBinary(int rowId, int count, byte[] src, int srcIndex) Set ints from binary, need use UNSAFE to copy.
void	setLong(int rowId, long value) Set long at rowId with the provided value.
void	setLongsFromBinary(int rowId, int count, byte[] src, int srcIndex) Set longs from binary, need use UNSAFE to copy.
void	setNullAt(int rowId) Set null at rowId.
void	setNulls(int rowId, int count) Set nulls from rowId to rowId + count (exclude).

Methods inherited from class java.lang.Object

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

Constructor Detail

ParquetDecimalVector

public ParquetDecimalVector(ColumnVector vector)

Method Detail

getDecimal

public Decimal getDecimal(int i,
                          int precision,
                          int scale)

Specified by:

getDecimal in interface DecimalColumnVector

getVector

public ColumnVector getVector()

isNullAt

public boolean isNullAt(int i)

Specified by:

isNullAt in interface ColumnVector

reset

public void reset()

Description copied from interface: WritableColumnVector

Resets the column to default state.

Specified by:

reset in interface WritableColumnVector

setNullAt

public void setNullAt(int rowId)

Description copied from interface: WritableColumnVector

Set null at rowId.

Specified by:

setNullAt in interface WritableColumnVector

setNulls

public void setNulls(int rowId,
                     int count)

Description copied from interface: WritableColumnVector

Set nulls from rowId to rowId + count (exclude).

Specified by:

setNulls in interface WritableColumnVector

fillWithNulls

public void fillWithNulls()

Description copied from interface: WritableColumnVector

Fill the column vector with nulls.

Specified by:

fillWithNulls in interface WritableColumnVector

setDictionary

public void setDictionary(Dictionary dictionary)

Description copied from interface: WritableColumnVector

Set the dictionary, it should work with dictionary ids.

Specified by:

setDictionary in interface WritableColumnVector

hasDictionary

public boolean hasDictionary()

Description copied from interface: WritableColumnVector

Check if there's a dictionary.

Specified by:

hasDictionary in interface WritableColumnVector

reserveDictionaryIds

public WritableIntVector reserveDictionaryIds(int capacity)

Description copied from interface: WritableColumnVector

Reserve a integer column for ids of dictionary. The size of return WritableIntVector should be equal to or bigger than capacity. DictionaryIds must inconsistent with WritableColumnVector.setDictionary(org.apache.paimon.data.columnar.Dictionary). We don't support a mix of dictionary.

Specified by:

reserveDictionaryIds in interface WritableColumnVector

getDictionaryIds

public WritableIntVector getDictionaryIds()

Description copied from interface: WritableColumnVector

Get reserved dictionary ids.

Specified by:

getDictionaryIds in interface WritableColumnVector

getBytes

public BytesColumnVector.Bytes getBytes(int i)

Specified by:

getBytes in interface BytesColumnVector

appendBytes

public void appendBytes(int rowId,
                        byte[] value,
                        int offset,
                        int length)

Description copied from interface: WritableBytesVector

Append byte[] at rowId with the provided value. Note: Must append values according to the order of rowId, can not random append.

Specified by:

appendBytes in interface WritableBytesVector

fill

public void fill(byte[] value)

Description copied from interface: WritableBytesVector

Fill the column vector with the provided value.

Specified by:

fill in interface WritableBytesVector

getInt

public int getInt(int i)

Specified by:

getInt in interface IntColumnVector

setInt

public void setInt(int rowId,
                   int value)

Description copied from interface: WritableIntVector

Set int at rowId with the provided value.

Specified by:

setInt in interface WritableIntVector

setIntsFromBinary

public void setIntsFromBinary(int rowId,
                              int count,
                              byte[] src,
                              int srcIndex)

Description copied from interface: WritableIntVector

Set ints from binary, need use UNSAFE to copy.

Specified by:

setIntsFromBinary in interface WritableIntVector

Parameters:

rowId - set start rowId.

count - count for int, so the bytes size is count * 4.

src - source binary.

srcIndex - source binary index, it is the index for byte index.

setInts

public void setInts(int rowId,
                    int count,
                    int value)

Description copied from interface: WritableIntVector

Sets value to [rowId, rowId + count) by the value, this is data that repeats continuously.

Specified by:

setInts in interface WritableIntVector

setInts

public void setInts(int rowId,
                    int count,
                    int[] src,
                    int srcIndex)

Description copied from interface: WritableIntVector

Sets values from [src[srcIndex], src[srcIndex + count]) to [rowId, rowId + count).

Specified by:

setInts in interface WritableIntVector

fill

public void fill(int value)

Description copied from interface: WritableIntVector

Fill the column vector with the provided value.

Specified by:

fill in interface WritableIntVector

getLong

public long getLong(int i)

Specified by:

getLong in interface LongColumnVector

setLong

public void setLong(int rowId,
                    long value)

Description copied from interface: WritableLongVector

Set long at rowId with the provided value.

Specified by:

setLong in interface WritableLongVector

setLongsFromBinary

public void setLongsFromBinary(int rowId,
                               int count,
                               byte[] src,
                               int srcIndex)

Description copied from interface: WritableLongVector

Set longs from binary, need use UNSAFE to copy.

Specified by:

setLongsFromBinary in interface WritableLongVector

Parameters:

rowId - set start rowId.

count - count for long, so the bytes size is count * 8.

src - source binary.

srcIndex - source binary index, it is the index for byte index.

fill

public void fill(long value)

Description copied from interface: WritableLongVector

Fill the column vector with the provided value.

Specified by:

fill in interface WritableLongVector