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.