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
