Class 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 Detail

      • ParquetDictionary

        public ParquetDictionary​(org.apache.parquet.column.Dictionary dictionary,
                                 org.apache.parquet.column.ColumnDescriptor descriptor)
    • Method Detail

      • decodeToInt

        public int decodeToInt​(int id)
        Specified by:
        decodeToInt in interface org.apache.flink.table.data.columnar.vector.Dictionary
      • decodeToLong

        public long decodeToLong​(int id)
        Specified by:
        decodeToLong in interface org.apache.flink.table.data.columnar.vector.Dictionary
      • decodeToFloat

        public float decodeToFloat​(int id)
        Specified by:
        decodeToFloat in interface org.apache.flink.table.data.columnar.vector.Dictionary
      • decodeToDouble

        public double decodeToDouble​(int id)
        Specified by:
        decodeToDouble in interface org.apache.flink.table.data.columnar.vector.Dictionary
      • decodeToBinary

        public byte[] decodeToBinary​(int id)
        Specified by:
        decodeToBinary in interface org.apache.flink.table.data.columnar.vector.Dictionary
      • decodeToTimestamp

        public org.apache.flink.table.data.TimestampData decodeToTimestamp​(int id)
        Specified by:
        decodeToTimestamp in interface org.apache.flink.table.data.columnar.vector.Dictionary