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 Description static <SplitT extends org.apache.flink.connector.file.src.FileSourceSplit>
ParquetColumnarRowInputFormat<SplitT>ParquetColumnarRowInputFormat. createPartitionedFormat(org.apache.hadoop.conf.Configuration hadoopConfig, org.apache.flink.table.types.logical.RowType producedRowType, org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.table.data.RowData> producedTypeInfo, List<String> partitionKeys, org.apache.flink.connector.file.table.PartitionFieldExtractor<SplitT> extractor, int batchSize, boolean isUtcTimestamp, boolean isCaseSensitive)Create a partitionedParquetColumnarRowInputFormat, the partition columns can be generated byPath.
-