This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git
from 21bfe4274 [flink] fix same primary key cannot be inserted again after
deletion in Partial Update merge engine. (#4248)
add 3120722b1 [spark] Support push down aggregate (#4259)
No new revisions were added by this update.
Summary of changes:
.../paimon/spark/PaimonBaseScanBuilder.scala | 23 +++--
.../org/apache/paimon/spark/PaimonLocalScan.scala} | 26 +++--
.../apache/paimon/spark/PaimonScanBuilder.scala | 56 ++++++++++-
.../org/apache/paimon/spark/PaimonSplitScan.scala | 2 +-
.../paimon/spark/aggregate/LocalAggregator.scala | 109 +++++++++++++++++++++
.../paimon/spark/sql/PushDownAggregatesTest.scala | 99 +++++++++++++++++++
6 files changed, 295 insertions(+), 20 deletions(-)
copy
paimon-spark/{paimon-spark-3.1/src/main/scala/org/apache/paimon/spark/PaimonScan.scala
=>
paimon-spark-common/src/main/scala/org/apache/paimon/spark/PaimonLocalScan.scala}
(64%)
create mode 100644
paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/aggregate/LocalAggregator.scala
create mode 100644
paimon-spark/paimon-spark-common/src/test/scala/org/apache/paimon/spark/sql/PushDownAggregatesTest.scala
