public class MergeIntoProcedure extends ProcedureBase
-- NOTE: use '' as placeholder for optional arguments
-- IMPORTANT: Use 'TRUE' if you want to delete data without filter condition.
-- If matchedDeleteCondition='', it will ignore matched-delete action!
CALL sys.merge_into(
'targetTableId',
'targetAlias',
'sourceSqls',
'sourceTable',
'mergeCondition',
'matchedUpsertCondition',
'matchedUpsertSetting',
'notMatchedInsertCondition',
'notMatchedInsertValues',
'matchedDeleteCondition'
)
This procedure will be forced to use batch environments. Compared to MergeIntoAction
,
this procedure doesn't provide arguments to control not-matched-by-source behavior because they
are not commonly used and will make the methods too complex to use.
Modifier and Type | Field and Description |
---|---|
static String |
IDENTIFIER |
catalog
Constructor and Description |
---|
MergeIntoProcedure() |
Modifier and Type | Method and Description |
---|---|
String[] |
call(org.apache.flink.table.procedure.ProcedureContext procedureContext,
String targetTableId,
String targetAlias,
String sourceSqls,
String sourceTable,
String mergeCondition,
String matchedUpsertCondition,
String matchedUpsertSetting,
String notMatchedInsertCondition,
String notMatchedInsertValues,
String matchedDeleteCondition,
String notMatchedBySourceUpsertCondition,
String notMatchedBySourceUpsertSetting,
String notMatchedBySourceDeleteCondition) |
String |
identifier()
Returns a unique identifier among same factory interfaces.
|
execute, execute, execute, notnull, nullable, optionalConfigMap, table, withCatalog
public static final String IDENTIFIER
public String[] call(org.apache.flink.table.procedure.ProcedureContext procedureContext, String targetTableId, String targetAlias, String sourceSqls, String sourceTable, String mergeCondition, String matchedUpsertCondition, String matchedUpsertSetting, String notMatchedInsertCondition, String notMatchedInsertValues, String matchedDeleteCondition, String notMatchedBySourceUpsertCondition, String notMatchedBySourceUpsertSetting, String notMatchedBySourceDeleteCondition)
public String identifier()
Factory
For consistency, an identifier should be declared as one lower case word (e.g. kafka
). If multiple factories exist for different versions, a version should be appended
using "-" (e.g. elasticsearch-7
).
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.