This is an automated email from the ASF dual-hosted git repository.
zouxxyy pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git
from e5ac69337b [flink] Support clone external Hive sources to Paimon table
(#5480)
add b44824452e [spark] Add paimon bucket function (#5242)
No new revisions were added by this update.
Summary of changes:
.../paimon/spark/SparkInternalRowWrapper.java | 5 +-
.../spark/catalog/functions/PaimonFunctions.java | 169 -----------
.../spark/catalog/functions/PaimonFunctions.scala | 138 +++++++++
.../paimon/spark/commands/BucketExpression.scala | 50 ++--
.../catalog/functions/BucketFunctionTest.java | 316 +++++++++++++++++++++
.../paimon/spark/sql/PaimonFunctionTest.scala | 3 +-
6 files changed, 486 insertions(+), 195 deletions(-)
delete mode 100644
paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/catalog/functions/PaimonFunctions.java
create mode 100644
paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/catalog/functions/PaimonFunctions.scala
create mode 100644
paimon-spark/paimon-spark-ut/src/test/java/org/apache/paimon/spark/catalog/functions/BucketFunctionTest.java
