key value to emit
left value to emit
right value to emit
output value for a single row, eg: (K, (V, W))
or (K, (V, Option[W]))
Emit values for left-side only key
Emit values for left-side only key
Emit values for right-side only key
Emit values for right-side only key
Called after all values for a key has been emitted.
Called after all values for a key has been emitted.
This will be called after each 'inner' key join, and once more on task completion to ensure we cleanup any intermediate spill files and release memory back to the executor when we are done with this key.
Emit both left
and right
values for the given key
Emit both left
and right
values for the given key
Base implementation for spillable merge-join Joiner that contains a default implementation for
inner
that will accumulate all right values into a spillable collection.Exposes an
emit
method to allow each implementation to format the output tuple accordingly