This is an automated email from the ASF dual-hosted git repository.
czweng pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git
from 8ade15fa3a [spark] Fix load function with SparkGenericCatalog (#4741)
add 3a9bed2134 [flink] Support nested projection pushdown (#4667)
No new revisions were added by this update.
Summary of changes:
.../apache/paimon/table/source/ReadBuilder.java | 13 --
.../apache/paimon/utils/FormatReaderMapping.java | 56 +++--
.../apache/paimon/table/IncrementalTableTest.java | 2 +-
.../org/apache/paimon/table/TableTestBase.java | 2 +-
.../paimon/table/system/BucketsTableTest.java | 2 +-
.../paimon/table/system/PartitionsTableTest.java | 6 +-
.../paimon/flink/NestedProjectedRowData.java | 246 +++++++++++++++++++++
.../java/org/apache/paimon/flink/Projection.java | 197 +++++++++++++++++
.../flink/source/ContinuousFileStoreSource.java | 8 +-
.../paimon/flink/source/FileStoreSourceReader.java | 6 +-
.../flink/source/FlinkRecordsWithSplitIds.java | 10 +-
.../apache/paimon/flink/source/FlinkSource.java | 15 +-
.../paimon/flink/source/FlinkSourceBuilder.java | 51 ++++-
.../paimon/flink/source/FlinkTableSource.java | 5 +-
.../flink/source/LogHybridSourceFactory.java | 24 +-
.../paimon/flink/source/StaticFileStoreSource.java | 8 +-
.../paimon/flink/source/SystemTableSource.java | 29 ++-
.../align/AlignedContinuousFileStoreSource.java | 10 +-
.../flink/source/align/AlignedSourceReader.java | 6 +-
.../flink/source/operator/MonitorSource.java | 6 +-
.../paimon/flink/source/operator/ReadOperator.java | 17 +-
.../org/apache/paimon/flink/ProjectionTest.java | 72 ++++++
.../flink/source/FileStoreSourceMetricsTest.java | 2 +-
.../flink/source/FileStoreSourceReaderTest.java | 1 +
.../flink/source/FlinkRecordsWithSplitIdsTest.java | 3 +-
.../flink/source/ProjectionPushDownITCase.java | 149 +++++++++++++
.../source/align/AlignedSourceReaderTest.java | 3 +-
.../flink/source/operator/OperatorSourceTest.java | 4 +-
28 files changed, 865 insertions(+), 88 deletions(-)
create mode 100644
paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/NestedProjectedRowData.java
create mode 100644
paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/ProjectionTest.java
create mode 100644
paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/source/ProjectionPushDownITCase.java
