From f510e48a3944bdcb80e66ff37da42ebf0da16d70 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=96=86=E5=AE=87?= Date: Thu, 29 Jan 2026 10:56:02 +0800 Subject: [PATCH] [docs] add description for data_evolution_merge_into procedure --- docs/content/flink/procedures.md | 29 +++++++++++++++++++++++++++++ 1 file changed, 29 insertions(+) diff --git a/docs/content/flink/procedures.md b/docs/content/flink/procedures.md index f5ed938f96be..cbbf88b32393 100644 --- a/docs/content/flink/procedures.md +++ b/docs/content/flink/procedures.md @@ -328,6 +328,35 @@ All available procedures are listed below. not_matched_insert_values => '*')

+ + data_evolution_merge_into + + -- Use indexed argument
+ CALL [catalog].sys.data_evolution_merge_into('targetTable','targetAlias',
+ 'sourceSqls','sourceTable','mergeCondition','matchedUpdateSet',sinkParallelism)

+ -- Use named argument
+ CALL [catalog].sys.data_evolution_merge_into(
+ target_table => 'identifier',
+ target_alias => 'targetAlias',
+ source_sqls => 'sourceSqls',
+ source_table => 'sourceTable',
+ merge_condition => 'mergeCondition',
+ matched_update_set => 'matchedUpdateSet',
+ sink_parallelism => sinkParallelism)

+ + To perform "MERGE INTO" syntax specially implemented for data-evolution tables. Please see data evolution for more information. + + -- for Flink 1.18
+ CALL [catalog].sys.data_evolution_merge_into('default.T', '', '', 'S', 'T.id=S.id', 'name=S.name', 2)

+ -- for Flink 1.19 and later
+ CALL [catalog].sys.data_evolution_merge_into(
+ target_table => 'default.T',
+ source_table => 'S',
+ merge_condition => 'T.id=S.id',
+ matched_update_set => 'name=S.name',
+ sink_parallelism => 2) + + remove_orphan_files