This is an automated email from the ASF dual-hosted git repository.
godfrey pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 74f90d722f7 [FLINK-28250][Connector/Kafka] Fix exactly-once Kafka Sink
out of memory
add 4bafbe25060 [FLINK-27990][table-planner] Parquet format supports
reporting statistics
No new revisions were added by this update.
Summary of changes:
flink-formats/flink-parquet/pom.xml | 8 +
.../formats/parquet/ParquetFileFormatFactory.java | 280 +++++++++++++++++-
.../vector/reader/TimestampColumnReader.java | 2 +-
.../ParquetFileSystemStatisticsReportTest.java | 53 ++++
.../parquet/ParquetFormatStatisticsReportTest.java | 198 +++++++++++++
flink-formats/pom.xml | 1 +
.../utils/CatalogTableStatisticsConverter.java | 7 +-
.../planner/catalog/CatalogStatisticsTest.java | 6 +-
.../planner/utils/StatisticsReportTestBase.java | 315 +++++++++++++++++++++
9 files changed, 860 insertions(+), 10 deletions(-)
create mode 100644
flink-formats/flink-parquet/src/test/java/org/apache/flink/formats/parquet/ParquetFileSystemStatisticsReportTest.java
create mode 100644
flink-formats/flink-parquet/src/test/java/org/apache/flink/formats/parquet/ParquetFormatStatisticsReportTest.java
create mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/utils/StatisticsReportTestBase.java
