You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by go...@apache.org on 2022/07/22 04:38:01 UTC
[flink] branch master updated (cfc5d724217 -> 9db9e19aec1)
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 cfc5d724217 [FLINK-28377][network] Decrease the memory size per request for sort-shuffle data read from 8M to 4M
add 559964a656c [FLINK-28491][table-planner] Introduce HyperLogLogPlusPlus
add c1e66fce8c8 [FLINK-28491][table-planner] Refactor AggFunctionTestBase: Allows its input type and its output type to be different
add 9db9e19aec1 [FLINK-28491][table-planner] Introduce APPROX_COUNT_DISTINCT aggregate function for batch sql
No new revisions were added by this update.
Summary of changes:
.../functions/sql/FlinkSqlOperatorTable.java | 2 +
.../planner/plan/utils/AggFunctionFactory.scala | 48 +-
.../table/planner/plan/utils/RelExplainUtil.scala | 10 +-
.../aggfunctions/AggFunctionTestBase.java | 88 +-
.../BatchApproxCountDistinctAggFunctionTest.java | 377 ++
...FirstLastValueAggFunctionWithOrderTestBase.java | 5 +-
.../FirstValueAggFunctionWithoutOrderTest.java | 2 +-
...alueWithRetractAggFunctionWithoutOrderTest.java | 2 +-
.../functions/aggfunctions/LagAggFunctionTest.java | 2 +-
.../LastValueAggFunctionWithoutOrderTest.java | 2 +-
...alueWithRetractAggFunctionWithoutOrderTest.java | 2 +-
.../ListAggWithRetractAggFunctionTest.java | 2 +-
.../ListAggWsWithRetractAggFunctionTest.java | 10 +-
.../MaxWithRetractAggFunctionTest.java | 2 +-
.../MinWithRetractAggFunctionTest.java | 2 +-
.../plan/batch/sql/agg/SortAggregateTest.xml | 107 +
.../plan/batch/sql/agg/SortAggregateTest.scala | 24 +-
.../plan/stream/sql/agg/AggregateTest.scala | 5 +
.../runtime/batch/sql/TableSourceITCase.scala | 7 +-
.../runtime/batch/sql/agg/SortAggITCase.scala | 55 +
.../runtime/stream/sql/TableSourceITCase.scala | 23 +-
.../table/planner/runtime/utils/TestData.scala | 14 +-
.../BatchApproxCountDistinctAggFunctions.java | 340 ++
.../functions/aggregate/hyperloglog/HllBuffer.java | 29 +-
.../aggregate/hyperloglog/HyperLogLogPlusPlus.java | 4995 ++++++++++++++++++++
.../functions/aggregate/hyperloglog/XXH64.java | 159 +
.../hyperloglog/HyperLogLogPlusPlusTest.java | 172 +
tools/maven/suppressions.xml | 1 +
28 files changed, 6393 insertions(+), 94 deletions(-)
create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/aggfunctions/BatchApproxCountDistinctAggFunctionTest.java
create mode 100644 flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/aggregate/BatchApproxCountDistinctAggFunctions.java
copy flink-formats/flink-parquet/src/test/java/org/apache/flink/formats/parquet/avro/Datum.java => flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/aggregate/hyperloglog/HllBuffer.java (67%)
create mode 100644 flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/aggregate/hyperloglog/HyperLogLogPlusPlus.java
create mode 100644 flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/aggregate/hyperloglog/XXH64.java
create mode 100644 flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/functions/aggregate/hyperloglog/HyperLogLogPlusPlusTest.java