Class ParquetDictionary
- java.lang.Object
-
- org.apache.flink.formats.parquet.vector.ParquetDictionary
-
- All Implemented Interfaces:
org.apache.flink.table.data.columnar.vector.Dictionary
public final class ParquetDictionary extends Object implements org.apache.flink.table.data.columnar.vector.Dictionary
Parquet dictionary.
-
-
Constructor Summary
Constructors Constructor Description ParquetDictionary(org.apache.parquet.column.Dictionary dictionary, org.apache.parquet.column.ColumnDescriptor descriptor)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description byte[]decodeToBinary(int id)doubledecodeToDouble(int id)floatdecodeToFloat(int id)intdecodeToInt(int id)longdecodeToLong(int id)org.apache.flink.table.data.TimestampDatadecodeToTimestamp(int id)
-
-
-
Method Detail
-
decodeToInt
public int decodeToInt(int id)
- Specified by:
decodeToIntin interfaceorg.apache.flink.table.data.columnar.vector.Dictionary
-
decodeToLong
public long decodeToLong(int id)
- Specified by:
decodeToLongin interfaceorg.apache.flink.table.data.columnar.vector.Dictionary
-
decodeToFloat
public float decodeToFloat(int id)
- Specified by:
decodeToFloatin interfaceorg.apache.flink.table.data.columnar.vector.Dictionary
-
decodeToDouble
public double decodeToDouble(int id)
- Specified by:
decodeToDoublein interfaceorg.apache.flink.table.data.columnar.vector.Dictionary
-
decodeToBinary
public byte[] decodeToBinary(int id)
- Specified by:
decodeToBinaryin interfaceorg.apache.flink.table.data.columnar.vector.Dictionary
-
decodeToTimestamp
public org.apache.flink.table.data.TimestampData decodeToTimestamp(int id)
- Specified by:
decodeToTimestampin interfaceorg.apache.flink.table.data.columnar.vector.Dictionary
-
-