You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@paimon.apache.org by lz...@apache.org on 2024/09/26 06:47:17 UTC

(paimon) branch master updated (21bfe4274 -> 3120722b1)

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