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 2ff82cda7 [flink] extend merge_into procedure to support
notMatchedBySourceUpsert/Delete. (#4314)
add 95897b5af [flink] Flink LookupTable support cache row filter (#4312)
No new revisions were added by this update.
Summary of changes:
.../apache/paimon/table/query/LocalTableQuery.java | 29 ++++-
.../org/apache/paimon/table/TableTestBase.java | 14 ++
.../flink/lookup/FileStoreLookupFunction.java | 10 ++
.../paimon/flink/lookup/FullCacheLookupTable.java | 10 +-
.../paimon/flink/lookup/LookupStreamingReader.java | 10 +-
.../apache/paimon/flink/lookup/LookupTable.java | 3 +
.../flink/lookup/PrimaryKeyPartialLookupTable.java | 36 ++++--
.../paimon/flink/lookup/LookupTableTest.java | 144 +++++++++++++++++++++
8 files changed, 238 insertions(+), 18 deletions(-)
