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 and Description
ParquetFormatStatisticsReportUtil()

Method Summary

Modifier and Type	Method and Description
static TableStats	getTableStatistics(List<Path> files, DataType producedDataType, org.apache.hadoop.conf.Configuration hadoopConfig, boolean isUtcTimestamp)
static TableStats	getTableStatistics(List<Path> files, 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 TableStats getTableStatistics(List<Path> files,
                                            DataType producedDataType,
                                            org.apache.hadoop.conf.Configuration hadoopConfig,
                                            boolean isUtcTimestamp)

getTableStatistics

public static TableStats getTableStatistics(List<Path> files,
                                            DataType producedDataType,
                                            org.apache.hadoop.conf.Configuration hadoopConfig,
                                            boolean isUtcTimestamp,
                                            int statisticsThreadNum)