This is an automated email from the ASF dual-hosted git repository.
guoweijie pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 0c338ae6d21 [FLINK-36751] Fix PausableRelativeClock does not pause
when the source only has one split
add 59dc491f87e [FLINK-35825][hive] HiveTableSource supports report
statistics for text file
No new revisions were added by this update.
Summary of changes:
.../flink/connectors/hive/HiveTableSource.java | 10 +-
.../hive/util/TextFormatStatisticsReportUtil.java | 127 +++++++++++++++++++++
.../hive/HiveTableSourceStatisticsReportTest.java | 29 ++++-
.../util/TextFormatStatisticsReportUtilTest.java | 96 ++++++++++++++++
.../resources/explain/testAvgAggFunctionPlan.out | 22 ++--
.../explain/testCountAggFunctionFallbackPlan.out | 44 ++++---
.../resources/explain/testCountAggFunctionPlan.out | 41 ++++---
.../resources/explain/testMaxAggFunctionPlan.out | 22 ++--
.../resources/explain/testMinAggFunctionPlan.out | 22 ++--
.../resources/explain/testSumAggFunctionPlan.out | 22 ++--
10 files changed, 353 insertions(+), 82 deletions(-)
create mode 100644
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/util/TextFormatStatisticsReportUtil.java
create mode 100644
flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/util/TextFormatStatisticsReportUtilTest.java
