Returns a MergeBuilderAsyncActor object that can be used to execute MergeBuilder actions asynchronously.

Example:

val target = session.table(tableName)
val source = Seq((10, "new")).toDF("id", "desc")
val asyncJob = target
  .merge(source, target("id") === source("id"))
  .whenMatched
  .update(Map(target("desc") -> source("desc")))
  .async
  .collect()
// At this point, the thread is not blocked. You can perform additional work before
// calling asyncJob.getResult() to retrieve the results of the action.
// NOTE: getResult() is a blocking call.
val mergeResult = asyncJob.getResult()

Executes the merge action and returns a MergeResult, representing number of rows inserted, updated and deleted by this merge action.

Adds a matched clause into the merge action. It matches all rows in target that satisfy <joinExpr> while also satisfying <condition>. Returns a MatchedClauseBuilder which provides APIs to define actions to take when a row is matched.

For example:

target.merge(source, target("id") === source("id")).whenMatched(target("value") === lit(0))

Adds a matched clause where a row in the Updatable target is matched if its id equals the id of a row in the DataFrame source and its value equals 0.

Adds a matched clause into the merge action. It matches all remaining rows in target that satisfy <joinExpr>. Returns a MatchedClauseBuilder which provides APIs to define actions to take when a row is matched.

For example:

target.merge(source, target("id") === source("id")).whenMatched

Adds a matched clause where a row in the Updatable target is matched if its id equals the id of a row in the DataFrame source.

Caution: Since it matches all remaining rows, no more whenMatched calls will be accepted beyond this call.

Adds a not matched clause into the merge action. It matches all rows in source that do not satisfy <joinExpr> but satisfy <condition>. Returns a MatchedClauseBuilder which provides APIs to define actions to take when a row is matched.

For example:

target.merge(source, target("id") === source("id"))
.whenNotMatched(source("value") === lit(0))

Adds a not matched clause where a row in the DataFrame source is not matched if its id does not equal the id of any row in the Updatable source and its value equals 0.

Adds a not matched clause into the merge action. It matches all remaining rows in source that do not satisfy <joinExpr>. Returns a MatchedClauseBuilder which provides APIs to define actions to take when a row is not matched.

For example:

target.merge(source, target("id") === source("id")).whenNotMatched

Adds a not matched clause where a row in the DataFrame source is not matched if its id does not equal the id of any row in the Updatable target.

Caution: Since it matches all remaining rows, no more whenNotMatched calls will be accepted beyond this call.