Class VectorizedColumnIterator


  • public class VectorizedColumnIterator
    extends BaseColumnIterator
    Vectorized version of the ColumnIterator that reads column values in data pages of a column in a row group in a batched fashion.
    • Constructor Detail

      • VectorizedColumnIterator

        public VectorizedColumnIterator​(org.apache.parquet.column.ColumnDescriptor desc,
                                        java.lang.String writerVersion,
                                        boolean setArrowValidityVector)
    • Method Detail

      • setBatchSize

        public void setBatchSize​(int batchSize)
      • setRowGroupInfo

        public org.apache.parquet.column.Dictionary setRowGroupInfo​(org.apache.parquet.column.page.PageReader store,
                                                                    boolean allPagesDictEncoded)
      • nextBatchIntegers

        public void nextBatchIntegers​(org.apache.arrow.vector.FieldVector fieldVector,
                                      int typeWidth,
                                      NullabilityHolder holder)
      • nextBatchDictionaryIds

        public void nextBatchDictionaryIds​(org.apache.arrow.vector.IntVector vector,
                                           NullabilityHolder holder)
      • nextBatchLongs

        public void nextBatchLongs​(org.apache.arrow.vector.FieldVector fieldVector,
                                   int typeWidth,
                                   NullabilityHolder holder)
      • nextBatchTimestampMillis

        public void nextBatchTimestampMillis​(org.apache.arrow.vector.FieldVector fieldVector,
                                             int typeWidth,
                                             NullabilityHolder holder)
      • nextBatchFloats

        public void nextBatchFloats​(org.apache.arrow.vector.FieldVector fieldVector,
                                    int typeWidth,
                                    NullabilityHolder holder)
      • nextBatchDoubles

        public void nextBatchDoubles​(org.apache.arrow.vector.FieldVector fieldVector,
                                     int typeWidth,
                                     NullabilityHolder holder)
      • nextBatchIntLongBackedDecimal

        public void nextBatchIntLongBackedDecimal​(org.apache.arrow.vector.FieldVector fieldVector,
                                                  int typeWidth,
                                                  NullabilityHolder nullabilityHolder)
      • nextBatchFixedLengthDecimal

        public void nextBatchFixedLengthDecimal​(org.apache.arrow.vector.FieldVector fieldVector,
                                                int typeWidth,
                                                NullabilityHolder nullabilityHolder)
      • nextBatchVarWidthType

        public void nextBatchVarWidthType​(org.apache.arrow.vector.FieldVector fieldVector,
                                          NullabilityHolder nullabilityHolder)
      • nextBatchFixedWidthBinary

        public void nextBatchFixedWidthBinary​(org.apache.arrow.vector.FieldVector fieldVector,
                                              int typeWidth,
                                              NullabilityHolder nullabilityHolder)
      • nextBatchBoolean

        public void nextBatchBoolean​(org.apache.arrow.vector.FieldVector fieldVector,
                                     NullabilityHolder nullabilityHolder)
      • producesDictionaryEncodedVector

        public boolean producesDictionaryEncodedVector()