DeltaMergeInto

DeltaMergeInto is a logical command (Spark SQL).

Creating Instance

DeltaMergeInto takes the following to be created:

  • Target LogicalPlan

  • Source LogicalPlan

  • Condition Expression

  • Matched Clauses (Seq[DeltaMergeIntoMatchedClause])

  • Optional Non-Matched Clause (Option[DeltaMergeIntoInsertClause])

  • Optional Migrated Schema (default: None)

DeltaMergeInto is created (using apply and resolveReferences utilities) when:

  • DeltaMergeBuilder is requested to execute

  • DeltaAnalysis logical resolution rule is requested to execute

Utilities

apply Factory

apply(
  target: LogicalPlan,
  source: LogicalPlan,
  condition: Expression,
  whenClauses: Seq[DeltaMergeIntoClause]): DeltaMergeInto

apply…​FIXME

apply is used when:

resolveReferences

resolveReferences(
  merge: DeltaMergeInto,
  conf: SQLConf)(
  resolveExpr: (Expression, LogicalPlan) => Expression): DeltaMergeInto

resolveReferences…​FIXME

resolveReferences is used when:

  • DeltaMergeBuilder is requested to execute

  • DeltaAnalysis logical resolution rule is requested to execute