JoinedRowProcessor¶

JoinedRowProcessor is...FIXME

Creating Instance¶

JoinedRowProcessor takes the following to be created:

• targetRowHasNoMatch Expression
• sourceRowHasNoMatch Expression
• Optional matchedCondition1 Expression
• Optional matchedOutput1 Expressions
• Optional matchedCondition2 Expression
• Optional matchedOutput2 Expressions
• Optional notMatchedCondition Expression
• Optional notMatchedOutput Expressions
• Optional noopCopyOutput Expression
• deleteRowOutput Expressions
• joinedAttributes Attributes
• joinedRowEncoder ExpressionEncoder
• outputRowEncoder ExpressionEncoder

JoinedRowProcessor is created when MergeIntoCommand is requested to writeAllChanges.

Processing Partition¶

processPartition(
  rowIterator: Iterator[Row]): Iterator[Row]

processPartition...FIXME

processPartition is used when MergeIntoCommand is requested to writeAllChanges.