xuyangzhong opened a new pull request, #2546: URL: https://github.com/apache/fluss/pull/2546
### Purpose This pr is based on https://github.com/apache/fluss/pull/2268 and do some refactoring work. Linked issue: close #2231 ### Brief change log - Added tests for normal PK tables with table.delete.behavior=IGNORE (not just first_row merge engine) - Added tests for joining on bucket key (not just full primary key) - Added tests verifying LEFT/RIGHT/FULL OUTER joins fail with appropriate validation error - Added test verifying cascade joins are not supported - Updated documentation for Flink 2.2 Delta Join with new supported features and limitations ### Tests - testDeltaJoinWithPrimaryKeyTableNoDeletes - normal PK table with delete.behavior=IGNORE - testDeltaJoinOnBucketKey - join on bucket key only - testDeltaJoinFailsWhenFilterOnNonUpsertKeys - filter on non-upsert-key columns fails - testDeltaJoinOnBucketKey - join on bucket key only (not full PK) - testDeltaJoinFailsWhenSourceHasDelete - source with DELETE records fails - testDeltaJoinFailsWhenJoinKeyNotContainIndex - join key not containing index fail - testDeltaJoinFailsWithLeftJoin - LEFT JOIN wouldn't be converted to DeltaJoin - testDeltaJoinFailsWithRightJoin - RIGHT JOIN wouldn't be converted to DeltaJoin - testDeltaJoinFailsWithFullOuterJoin - FULL OUTER JOIN wouldn't be converted to DeltaJoin - testDeltaJoinFailsWithCascadeJoin - cascade join wouldn't be converted to DeltaJoin ### API and Format No ### Documentation Yes - updated `docs/engine-flink/delta-joins.md` in Flink 2.2 part. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
