Package org.apache.flink.formats.parquet.utils

Class ParquetFormatStatisticsReportUtil

java.lang.Object

org.apache.flink.formats.parquet.utils.ParquetFormatStatisticsReportUtil

public class ParquetFormatStatisticsReportUtil
extends Object

Utils for Parquet format statistics report.

Constructor Summary

Constructors

Constructor	Description
ParquetFormatStatisticsReportUtil()

Method Summary

Modifier and Type	Method	Description
static org.apache.flink.table.plan.stats.TableStats	getTableStatistics(List<org.apache.flink.core.fs.Path> files, org.apache.flink.table.types.DataType producedDataType, org.apache.hadoop.conf.Configuration hadoopConfig, boolean isUtcTimestamp)
static org.apache.flink.table.plan.stats.TableStats	getTableStatistics(List<org.apache.flink.core.fs.Path> files, org.apache.flink.table.types.DataType producedDataType, org.apache.hadoop.conf.Configuration hadoopConfig, boolean isUtcTimestamp, int statisticsThreadNum)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ParquetFormatStatisticsReportUtil

public ParquetFormatStatisticsReportUtil()

Method Detail

getTableStatistics

public static org.apache.flink.table.plan.stats.TableStats getTableStatistics(List<org.apache.flink.core.fs.Path> files,
                                                                              org.apache.flink.table.types.DataType producedDataType,
                                                                              org.apache.hadoop.conf.Configuration hadoopConfig,
                                                                              boolean isUtcTimestamp)

getTableStatistics

public static org.apache.flink.table.plan.stats.TableStats getTableStatistics(List<org.apache.flink.core.fs.Path> files,
                                                                              org.apache.flink.table.types.DataType producedDataType,
                                                                              org.apache.hadoop.conf.Configuration hadoopConfig,
                                                                              boolean isUtcTimestamp,
                                                                              int statisticsThreadNum)