datafusion_physical_plan

Module joins

Source
Expand description

DataFusion Join implementations

Modules§

  • utils
    Join related functionality used both on logical and physical plans

Structs§

  • CrossJoinExec
    executes partitions in parallel and combines them into a set of partitions by combining all values from the left with all values on the right
  • HashJoinExec
    Join execution plan: Evaluates eqijoin predicates in parallel on multiple partitions using a hash table and an optional filter list to apply post join.
  • NestedLoopJoinExec
    NestedLoopJoinExec is build-probe join operator, whose main task is to perform joins without any equijoin conditions in ON clause.
  • SortMergeJoinExec
    join execution plan executes partitions in parallel and combines them into a set of partitions.
  • SymmetricHashJoinExec
    A symmetric hash join with range conditions is when both streams are hashed on the join key and the resulting hash tables are used to join the streams. The join is considered symmetric because the hash table is built on the join keys from both streams, and the matching of rows is based on the values of the join keys in both streams. This type of join is efficient in streaming context as it allows for fast lookups in the hash table, rather than having to scan through one or both of the streams to find matching rows, also it only considers the elements from the stream that fall within a certain sliding window (w/ range conditions), making it more efficient and less likely to store stale data. This enables operating on unbounded streaming data without any memory issues.

Enums§