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 185b2e57c9 [iceberg] Introduce Iceberg Table in Catalog (#6020)
add a2b23dcf08 [core][spark] Support UPDATE for row lineage (#6014)
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/paimon/schema/TableSchema.java | 3 +-
.../org/apache/paimon/table/SpecialFields.java | 15 +++-
.../paimon/operation/BaseAppendFileStoreWrite.java | 43 +++++------
.../apache/paimon/operation/FileStoreWrite.java | 6 ++
.../org/apache/paimon/table/sink/TableWrite.java | 4 ++
.../apache/paimon/table/sink/TableWriteImpl.java | 6 ++
.../apache/paimon/utils/FormatReaderMapping.java | 2 +-
.../AppendPreCommitCompactWorkerOperator.java | 6 ++
.../paimon/flink/compact/AppendTableCompactor.java | 6 ++
.../sql/{DDLTest.scala => RowLineageTest.scala} | 2 +-
.../apache/paimon/spark/sql/RowLineageTest.scala} | 2 +-
.../apache/paimon/spark/sql/RowLineageTest.scala} | 2 +-
.../apache/paimon/spark/sql/RowLineageTest.scala} | 2 +-
.../apache/paimon/spark/sql/RowLineageTest.scala} | 2 +-
.../paimon/spark/SparkInternalRowWrapper.java | 7 +-
.../paimon/spark/procedure/CompactProcedure.java | 9 ++-
.../org/apache/paimon/spark/SparkTableWrite.scala | 26 +++++--
.../paimon/spark/commands/PaimonCommand.scala | 1 -
.../paimon/spark/commands/PaimonSparkWriter.scala | 40 ++++++++---
.../spark/commands/UpdatePaimonTableCommand.scala | 25 +++++--
.../apache/paimon/spark/util/SparkRowUtils.scala | 21 ++----
.../apache/paimon/spark/sql/RowLineageTest.scala | 42 -----------
.../paimon/spark/sql/RowLineageTestBase.scala | 84 ++++++++++++++++++++++
23 files changed, 240 insertions(+), 116 deletions(-)
copy
paimon-spark/paimon-spark-3.2/src/test/scala/org/apache/paimon/spark/sql/{DDLTest.scala
=> RowLineageTest.scala} (94%)
copy
paimon-spark/{paimon-spark-3.2/src/test/scala/org/apache/paimon/spark/sql/DDLTest.scala
=>
paimon-spark-3.3/src/test/scala/org/apache/paimon/spark/sql/RowLineageTest.scala}
(94%)
copy
paimon-spark/{paimon-spark-3.2/src/test/scala/org/apache/paimon/spark/sql/DDLTest.scala
=>
paimon-spark-3.4/src/test/scala/org/apache/paimon/spark/sql/RowLineageTest.scala}
(94%)
copy
paimon-spark/{paimon-spark-3.2/src/test/scala/org/apache/paimon/spark/sql/DDLTest.scala
=>
paimon-spark-3.5/src/test/scala/org/apache/paimon/spark/sql/RowLineageTest.scala}
(94%)
copy
paimon-spark/{paimon-spark-3.2/src/test/scala/org/apache/paimon/spark/sql/DDLTest.scala
=>
paimon-spark-4.0/src/test/scala/org/apache/paimon/spark/sql/RowLineageTest.scala}
(94%)
delete mode 100644
paimon-spark/paimon-spark-ut/src/test/scala/org/apache/paimon/spark/sql/RowLineageTest.scala
create mode 100644
paimon-spark/paimon-spark-ut/src/test/scala/org/apache/paimon/spark/sql/RowLineageTestBase.scala
