Uses of Class
org.apache.flink.formats.parquet.ParquetColumnarRowInputFormat

Packages that use ParquetColumnarRowInputFormat

Package	Description
org.apache.flink.formats.parquet

Uses of ParquetColumnarRowInputFormat in org.apache.flink.formats.parquet

Methods in org.apache.flink.formats.parquet that return ParquetColumnarRowInputFormat

Modifier and Type

Method and Description

static <SplitT extends FileSourceSplit> ParquetColumnarRowInputFormat<SplitT>

ParquetColumnarRowInputFormat.createPartitionedFormat(org.apache.hadoop.conf.Configuration hadoopConfig, RowType producedRowType, TypeInformation<RowData> producedTypeInfo, List<String> partitionKeys, PartitionFieldExtractor<SplitT> extractor, int batchSize, boolean isUtcTimestamp, boolean isCaseSensitive) Create a partitioned ParquetColumnarRowInputFormat, the partition columns can be generated by Path.