Package org.apache.flink.formats.parquet.vector

Class ParquetDecimalVector

java.lang.Object

org.apache.flink.formats.parquet.vector.ParquetDecimalVector

All Implemented Interfaces:

org.apache.flink.table.data.columnar.vector.BytesColumnVector, org.apache.flink.table.data.columnar.vector.ColumnVector, org.apache.flink.table.data.columnar.vector.DecimalColumnVector, org.apache.flink.table.data.columnar.vector.IntColumnVector, org.apache.flink.table.data.columnar.vector.LongColumnVector, org.apache.flink.table.data.columnar.vector.writable.WritableBytesVector, org.apache.flink.table.data.columnar.vector.writable.WritableColumnVector, org.apache.flink.table.data.columnar.vector.writable.WritableIntVector, org.apache.flink.table.data.columnar.vector.writable.WritableLongVector

@Internal
public class ParquetDecimalVector
extends Object
implements org.apache.flink.table.data.columnar.vector.DecimalColumnVector, org.apache.flink.table.data.columnar.vector.writable.WritableLongVector, org.apache.flink.table.data.columnar.vector.writable.WritableIntVector, org.apache.flink.table.data.columnar.vector.writable.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.flink.table.data.columnar.vector.BytesColumnVector

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

Constructor Summary

Constructors

Constructor	Description
ParquetDecimalVector(org.apache.flink.table.data.columnar.vector.ColumnVector vector)

Method Summary

Modifier and Type	Method	Description
void	appendBytes(int rowId, byte[] value, int offset, int length)
void	fill(byte[] value)
void	fill(int value)
void	fill(long value)
void	fillWithNulls()
org.apache.flink.table.data.columnar.vector.BytesColumnVector.Bytes	getBytes(int i)
org.apache.flink.table.data.DecimalData	getDecimal(int i, int precision, int scale)
org.apache.flink.table.data.columnar.vector.writable.WritableIntVector	getDictionaryIds()
int	getInt(int i)
long	getLong(int i)
org.apache.flink.table.data.columnar.vector.ColumnVector	getVector()
boolean	hasDictionary()
boolean	isNullAt(int i)
org.apache.flink.table.data.columnar.vector.writable.WritableIntVector	reserveDictionaryIds(int capacity)
void	reset()
void	setDictionary(org.apache.flink.table.data.columnar.vector.Dictionary dictionary)
void	setInt(int rowId, int value)
void	setInts(int rowId, int count, int value)
void	setInts(int rowId, int count, int[] src, int srcIndex)
void	setIntsFromBinary(int rowId, int count, byte[] src, int srcIndex)
void	setLong(int rowId, long value)
void	setLongsFromBinary(int rowId, int count, byte[] src, int srcIndex)
void	setNullAt(int rowId)
void	setNulls(int rowId, int count)

Methods inherited from class java.lang.Object

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

Constructor Detail

ParquetDecimalVector

public ParquetDecimalVector(org.apache.flink.table.data.columnar.vector.ColumnVector vector)

Method Detail

getDecimal

public org.apache.flink.table.data.DecimalData getDecimal(int i,
                                                          int precision,
                                                          int scale)

Specified by:

getDecimal in interface org.apache.flink.table.data.columnar.vector.DecimalColumnVector

getVector

public org.apache.flink.table.data.columnar.vector.ColumnVector getVector()

isNullAt

public boolean isNullAt(int i)

Specified by:

isNullAt in interface org.apache.flink.table.data.columnar.vector.ColumnVector

reset

public void reset()

Specified by:

reset in interface org.apache.flink.table.data.columnar.vector.writable.WritableColumnVector

setNullAt

public void setNullAt(int rowId)

Specified by:

setNullAt in interface org.apache.flink.table.data.columnar.vector.writable.WritableColumnVector

setNulls

public void setNulls(int rowId,
                     int count)

Specified by:

setNulls in interface org.apache.flink.table.data.columnar.vector.writable.WritableColumnVector

fillWithNulls

public void fillWithNulls()

Specified by:

fillWithNulls in interface org.apache.flink.table.data.columnar.vector.writable.WritableColumnVector

setDictionary

public void setDictionary(org.apache.flink.table.data.columnar.vector.Dictionary dictionary)

Specified by:

setDictionary in interface org.apache.flink.table.data.columnar.vector.writable.WritableColumnVector

hasDictionary

public boolean hasDictionary()

Specified by:

hasDictionary in interface org.apache.flink.table.data.columnar.vector.writable.WritableColumnVector

reserveDictionaryIds

public org.apache.flink.table.data.columnar.vector.writable.WritableIntVector reserveDictionaryIds(int capacity)

Specified by:

reserveDictionaryIds in interface org.apache.flink.table.data.columnar.vector.writable.WritableColumnVector

getDictionaryIds

public org.apache.flink.table.data.columnar.vector.writable.WritableIntVector getDictionaryIds()

Specified by:

getDictionaryIds in interface org.apache.flink.table.data.columnar.vector.writable.WritableColumnVector

getBytes

public org.apache.flink.table.data.columnar.vector.BytesColumnVector.Bytes getBytes(int i)

Specified by:

getBytes in interface org.apache.flink.table.data.columnar.vector.BytesColumnVector

appendBytes

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

Specified by:

appendBytes in interface org.apache.flink.table.data.columnar.vector.writable.WritableBytesVector

fill

public void fill(byte[] value)

Specified by:

fill in interface org.apache.flink.table.data.columnar.vector.writable.WritableBytesVector

getInt

public int getInt(int i)

Specified by:

getInt in interface org.apache.flink.table.data.columnar.vector.IntColumnVector

setInt

public void setInt(int rowId,
                   int value)

Specified by:

setInt in interface org.apache.flink.table.data.columnar.vector.writable.WritableIntVector

setIntsFromBinary

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

Specified by:

setIntsFromBinary in interface org.apache.flink.table.data.columnar.vector.writable.WritableIntVector

setInts

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

Specified by:

setInts in interface org.apache.flink.table.data.columnar.vector.writable.WritableIntVector

setInts

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

Specified by:

setInts in interface org.apache.flink.table.data.columnar.vector.writable.WritableIntVector

fill

public void fill(int value)

Specified by:

fill in interface org.apache.flink.table.data.columnar.vector.writable.WritableIntVector

getLong

public long getLong(int i)

Specified by:

getLong in interface org.apache.flink.table.data.columnar.vector.LongColumnVector

setLong

public void setLong(int rowId,
                    long value)

Specified by:

setLong in interface org.apache.flink.table.data.columnar.vector.writable.WritableLongVector

setLongsFromBinary

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

Specified by:

setLongsFromBinary in interface org.apache.flink.table.data.columnar.vector.writable.WritableLongVector

fill

public void fill(long value)

Specified by:

fill in interface org.apache.flink.table.data.columnar.vector.writable.WritableLongVector