This is an automated email from the ASF dual-hosted git repository.
lincoln pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from ee645841267 [FLINK-38976][runtime] Support zero job in an application
new 8ade28e18d3 [hotfix][core] Make RoaringBitmapData implement
Serializable and Remove unused wrap method
new 1c6943c3f71 [FLINK-39187][table] Add the built-in function
BITMAP_BUILD_AGG
new 26046c653a6 [FLINK-39187][table] Add the built-in function
BITMAP_AND_AGG, BITMAP_OR_AGG, BITMAP_XOR_AGG
new 62e7163f879 [FLINK-39187][table] Add new built-in functions to allow
direct cardinality return for bitmap aggregation
The 4 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../docs/sql/functions/built-in-functions.md | 4 +
.../docs/sql/functions/built-in-functions.md | 4 +
docs/data/sql_functions.yml | 74 ++++
docs/data/sql_functions_zh.yml | 82 +++-
.../flink/types/bitmap/RoaringBitmapData.java | 22 +-
.../apache/flink/types/RoaringBitmapDataTest.java | 6 -
.../docs/reference/pyflink.table/expressions.rst | 8 +
flink-python/pyflink/table/expression.py | 77 ++++
.../pyflink/table/tests/test_expression.py | 9 +
.../flink/table/api/internal/BaseExpressions.java | 93 ++++
.../functions/BuiltInFunctionDefinitions.java | 96 +++++
.../planner/plan/utils/AggFunctionFactory.scala | 100 +++++
.../planner/functions/BitmapAggFunctionITCase.java | 471 +++++++++++++++++++++
.../runtime/batch/sql/OverAggregateITCase.scala | 60 +++
.../runtime/stream/sql/AggregateITCase.scala | 153 +++++++
.../runtime/stream/sql/OverAggregateITCase.scala | 79 ++++
.../runtime/stream/sql/WindowAggregateITCase.scala | 54 +++
.../runtime/stream/table/AggregateITCase.scala | 70 +++
.../aggregate/AbstractBitmapAndAggFunction.java | 166 ++++++++
.../AbstractBitmapAndWithRetractAggFunction.java | 261 ++++++++++++
.../aggregate/AbstractBitmapBuildAggFunction.java | 130 ++++++
.../AbstractBitmapBuildWithRetractAggFunction.java | 234 ++++++++++
.../aggregate/AbstractBitmapOrAggFunction.java | 166 ++++++++
.../AbstractBitmapOrWithRetractAggFunction.java | 264 ++++++++++++
.../aggregate/AbstractBitmapXorAggFunction.java | 166 ++++++++
.../AbstractBitmapXorWithRetractAggFunction.java | 177 ++++++++
26 files changed, 2999 insertions(+), 27 deletions(-)
create mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/BitmapAggFunctionITCase.java
create mode 100644
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/aggregate/AbstractBitmapAndAggFunction.java
create mode 100644
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/aggregate/AbstractBitmapAndWithRetractAggFunction.java
create mode 100644
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/aggregate/AbstractBitmapBuildAggFunction.java
create mode 100644
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/aggregate/AbstractBitmapBuildWithRetractAggFunction.java
create mode 100644
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/aggregate/AbstractBitmapOrAggFunction.java
create mode 100644
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/aggregate/AbstractBitmapOrWithRetractAggFunction.java
create mode 100644
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/aggregate/AbstractBitmapXorAggFunction.java
create mode 100644
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/aggregate/AbstractBitmapXorWithRetractAggFunction.java
