Expand description

Delta join execution planning.

Delta joins are a join over multiple input relations, implemented by an independent dataflow path for each input. Each path is joined against the other inputs using a “lookup” operator, and the path results are collected and return as the output for the entire dataflow.

This implementation strategy allows us to re-use existing arrangements, and not create any new stateful operators.

Structs

  • A delta query is implemented by a set of paths, one for each input.
  • A delta query path is implemented by a sequences of stages,
  • A delta query stage performs a stream lookup into an arrangement.