This is an automated email from the ASF dual-hosted git repository.
fhueske pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 6dec8b4af65 [FLINK-40680] Bump openai-java dependency to 4.63.1
new c4e485a22d5 [FLINK-40666][table] Simplify SNAPSHOT function by
removing load_completed_condition argument
new 8460639e2b4 [FLINK-40666][table] Derive default SNAPSHOT
load_completed_time from query-start epoch
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../content.zh/docs/sql/reference/queries/joins.md | 10 +-
docs/content/docs/sql/reference/queries/joins.md | 10 +-
.../flink/sql/parser/FlinkSqlParserImplTest.java | 4 +-
.../functions/BuiltInFunctionDefinitions.java | 2 -
.../strategies/LateralSnapshotTypeStrategy.java | 91 ++----------------
.../LateralSnapshotInputTypeStrategyTest.java | 102 ++-------------------
.../LogicalJoinToLateralSnapshotJoinRule.java | 52 +++--------
.../plan/utils/LateralSnapshotJoinUtil.java | 30 ++++++
.../batch/sql/join/LateralSnapshotJoinTest.java | 6 --
.../batch/LateralSnapshotJoinTestPrograms.java | 1 -
.../LateralSnapshotJoinSemanticTestPrograms.java | 14 +--
.../stream/LateralSnapshotJoinTestPrograms.java | 5 +-
.../plan/stream/sql/ColumnExpansionTest.java | 2 -
.../plan/stream/sql/SnapshotTableFunctionTest.java | 3 -
.../stream/sql/join/LateralSnapshotJoinTest.java | 85 ++++++-----------
.../plan/utils/LateralSnapshotJoinUtilTest.java | 35 +++++++
.../stream/sql/join/LateralSnapshotJoinITCase.java | 8 +-
.../batch/sql/join/LateralSnapshotJoinTest.xml | 24 ++---
.../stream/sql/join/LateralSnapshotJoinTest.xml | 40 ++++----
19 files changed, 177 insertions(+), 347 deletions(-)
