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 2026/09/11 07:24:33 UTC

(paimon) branch master updated (4c3b7f56b6 -> e43e27ff24)

This is an automated email from the ASF dual-hosted git repository.

JingsongLi pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git


    from 4c3b7f56b6 [common] Normalize row-id IN literals inside Range.toRanges (#9630)
     add e43e27ff24 [spark] Support source table fileio for blob descriptors on spark (#9598)

No new revisions were added by this update.

Summary of changes:
 .../paimon/utils}/BlobDescriptorResolvingRow.java  | 171 +++++++++++++--
 .../paimon/table/BlobDescriptorReadUtils.java      |  67 ++++++
 .../flink/sink/BlobDescriptorResolvingRow.java     | 239 +--------------------
 .../org/apache/paimon/spark/PaimonBatch.scala      |  13 +-
 .../paimon/spark/PaimonPartitionReader.scala       |  17 +-
 .../spark/PaimonPartitionReaderFactory.scala       |  14 +-
 .../apache/paimon/spark/PostponeMergeOnRead.scala  |  25 ++-
 .../spark/execution/PostponeMergeOnReadExec.scala  |  37 +++-
 .../org/apache/paimon/spark/read/BaseScan.scala    |  14 +-
 .../spark/sources/PaimonMicroBatchStream.scala     |  15 +-
 .../apache/paimon/spark/SparkInternalRowTest.java  |  80 +++++++
 .../spark/sources/PaimonMicroBatchStreamTest.scala |  47 +++-
 .../org/apache/paimon/spark/sql/BlobTestBase.scala |  35 +++
 13 files changed, 491 insertions(+), 283 deletions(-)
 copy {paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink => paimon-common/src/main/java/org/apache/paimon/utils}/BlobDescriptorResolvingRow.java (58%)
 create mode 100644 paimon-core/src/main/java/org/apache/paimon/table/BlobDescriptorReadUtils.java