public class ParquetFileStatsExtractor extends Object implements FileStatsExtractor
FileStatsExtractor
for parquet files.Constructor and Description |
---|
ParquetFileStatsExtractor(org.apache.flink.table.types.logical.RowType rowType) |
public ParquetFileStatsExtractor(org.apache.flink.table.types.logical.RowType rowType)
public FieldStats[] extract(org.apache.flink.core.fs.Path path) throws IOException
extract
in interface FileStatsExtractor
IOException
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.