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 84a552b5eb [core] Support re-overwrite by spark for chain table (#7038)
     add 7af4d42c26 [variant] Refactor variant read to support clipping of 
nested variant (#7075)

No new revisions were added by this update.

Summary of changes:
 .../paimon/data/variant/PaimonShreddingUtils.java  |  31 ++-
 .../paimon/data/variant/VariantAccessInfo.java     | 109 --------
 .../data/variant/VariantAccessInfoUtils.java       | 121 ---------
 .../paimon/data/variant/VariantCastArgs.java       |  15 ++
 .../paimon/data/variant/VariantMetadataUtils.java  | 131 ++++++++++
 .../java/org/apache/paimon/format/FileFormat.java  |  12 -
 .../data/variant/VariantMetadataUtilsTest.java     | 155 +++++++++++
 .../paimon/io/ChainKeyValueFileReaderFactory.java  |   4 +-
 .../paimon/io/KeyValueFileReaderFactory.java       |  21 +-
 .../paimon/operation/DataEvolutionSplitRead.java   |  11 +-
 .../paimon/operation/MergeFileSplitRead.java       |  31 +--
 .../apache/paimon/operation/RawFileSplitRead.java  |  11 +-
 .../org/apache/paimon/operation/SplitRead.java     |   9 -
 .../paimon/table/format/FormatReadBuilder.java     |   6 -
 .../paimon/table/source/AbstractDataTableRead.java |   9 -
 .../paimon/table/source/AppendTableRead.java       |   9 -
 .../apache/paimon/table/source/InnerTableRead.java |   5 -
 .../paimon/table/source/KeyValueTableRead.java     |  11 -
 .../apache/paimon/table/source/ReadBuilder.java    |   9 -
 .../paimon/table/source/ReadBuilderImpl.java       |  20 +-
 .../source/splitread/IncrementalDiffSplitRead.java |   7 -
 .../apache/paimon/utils/FormatReaderMapping.java   |  13 +-
 .../paimon/flink/lookup/LookupCompactDiffRead.java |   7 -
 .../paimon/format/parquet/ParquetFileFormat.java   |  15 --
 .../format/parquet/ParquetReaderFactory.java       |  92 +++++--
 .../format/parquet/ParquetSchemaConverter.java     |   7 +-
 .../apache/paimon/format/parquet/VariantUtils.java |  56 +---
 .../format/parquet/reader/ParquetColumnVector.java |   2 +-
 .../format/parquet/reader/ParquetReaderUtil.java   | 141 ++++------
 .../paimon/format/parquet/type/ParquetField.java   |  17 +-
 .../format/parquet/type/ParquetGroupField.java     |  17 +-
 .../format/parquet/ParquetFormatReadWriteTest.java | 130 ----------
 .../parquet/reader/VariantShreddingReadTest.java   | 285 +++++++++++++++++++++
 .../writer/InferVariantShreddingWriteTest.java     | 128 ++++-----
 .../apache/paimon/spark/sql/VariantTestBase.scala  | 113 ++++++++
 35 files changed, 925 insertions(+), 835 deletions(-)
 delete mode 100644 
paimon-common/src/main/java/org/apache/paimon/data/variant/VariantAccessInfo.java
 delete mode 100644 
paimon-common/src/main/java/org/apache/paimon/data/variant/VariantAccessInfoUtils.java
 create mode 100644 
paimon-common/src/main/java/org/apache/paimon/data/variant/VariantMetadataUtils.java
 create mode 100644 
paimon-common/src/test/java/org/apache/paimon/data/variant/VariantMetadataUtilsTest.java
 create mode 100644 
paimon-format/src/test/java/org/apache/paimon/format/parquet/reader/VariantShreddingReadTest.java

Reply via email to