org.apache.paimon.format.parquet.reader

Class ParquetDecimalVector

java.lang.Object

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

All Implemented Interfaces:

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

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

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(WritableColumnVector vector)

Method Summary

Modifier and Type	Method and Description
void	addElementsAppended(int num)
void	appendInt(int v)
void	appendInts(int count, int v)
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)
int	getCapacity()
Decimal	getDecimal(int i, int precision, int scale)
WritableIntVector	getDictionaryIds() Get reserved dictionary ids.
int	getElementsAppended()
int	getInt(int i)
long	getLong(int i)
ColumnVector	getVector()
boolean	hasDictionary() Check if there's a dictionary.
boolean	isAllNull() Check if all values are null.
boolean	isNullAt(int i)
void	putByteArray(int rowId, byte[] value, int offset, int length) Append byte[] at rowId with the provided value.
void	reserve(int capacity)
WritableIntVector	reserveDictionaryIds(int capacity) Reserve a integer column for ids of dictionary.
void	reset() Resets the column to default state.
void	setAllNull() Set all values to null.
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

Methods inherited from interface org.apache.paimon.data.columnar.writable.WritableColumnVector

reserveAdditional

Methods inherited from interface org.apache.paimon.data.columnar.ColumnVector

getChildren

Constructor Detail

ParquetDecimalVector

public ParquetDecimalVector(WritableColumnVector 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

getCapacity

public int getCapacity()

Specified by:

getCapacity in interface ColumnVector

Specified by:

getCapacity in interface ElementCountable

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

setAllNull

public void setAllNull()

Description copied from interface: WritableColumnVector

Set all values to null.

Specified by:

setAllNull in interface WritableColumnVector

isAllNull

public boolean isAllNull()

Description copied from interface: WritableColumnVector

Check if all values are null.

Specified by:

isAllNull in interface WritableColumnVector

reserve

public void reserve(int capacity)

Specified by:

reserve in interface WritableColumnVector

getElementsAppended

public int getElementsAppended()

Specified by:

getElementsAppended in interface WritableColumnVector

addElementsAppended

public void addElementsAppended(int num)

Specified by:

addElementsAppended in interface WritableColumnVector

getBytes

public BytesColumnVector.Bytes getBytes(int i)

Specified by:

getBytes in interface BytesColumnVector

putByteArray

public void putByteArray(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:

putByteArray 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

appendInt

public void appendInt(int v)

Specified by:

appendInt in interface WritableIntVector

appendInts

public void appendInts(int count,
                       int v)

Specified by:

appendInts 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