Uses of Interface
org.apache.flink.formats.parquet.vector.reader.ColumnReader
-
Packages that use ColumnReader Package Description org.apache.flink.formats.parquet.vector org.apache.flink.formats.parquet.vector.reader -
-
Uses of ColumnReader in org.apache.flink.formats.parquet.vector
Methods in org.apache.flink.formats.parquet.vector that return ColumnReader Modifier and Type Method Description static ColumnReaderParquetSplitReaderUtil. createColumnReader(boolean isUtcTimestamp, org.apache.flink.table.types.logical.LogicalType fieldType, org.apache.parquet.schema.Type type, List<org.apache.parquet.column.ColumnDescriptor> columnDescriptors, org.apache.parquet.column.page.PageReadStore pages, int depth) -
Uses of ColumnReader in org.apache.flink.formats.parquet.vector.reader
Classes in org.apache.flink.formats.parquet.vector.reader that implement ColumnReader Modifier and Type Class Description classAbstractColumnReader<VECTOR extends org.apache.flink.table.data.columnar.vector.writable.WritableColumnVector>AbstractColumnReader.classArrayColumnReaderArrayColumnReader.classBaseVectorizedColumnReaderIt's column level Parquet reader which is used to read a batch of records for a column, part of the code is referred from Apache Hive and Apache Parquet.classBooleanColumnReaderBooleanColumnReader.classByteColumnReaderByteColumnReader.classBytesColumnReaderBytesColumnReader.classDoubleColumnReaderDoubleColumnReader.classFixedLenBytesColumnReader<VECTOR extends org.apache.flink.table.data.columnar.vector.writable.WritableColumnVector>Fixed length bytesColumnReader, just for decimal.classFloatColumnReaderFloatColumnReader.classIntColumnReaderIntColumnReader.classLongColumnReaderLongColumnReader.classMapColumnReaderMapColumnReader.classRowColumnReaderRowColumnReader.classShortColumnReaderShortColumnReader.classTimestampColumnReaderTimestampColumnReader.Constructor parameters in org.apache.flink.formats.parquet.vector.reader with type arguments of type ColumnReader Constructor Description RowColumnReader(List<ColumnReader> fieldReaders)
-