Deprecated: The each() function is deprecated. This message will be suppressed on further calls in /home/zhenxiangba/zhenxiangba.com/public_html/phproxy-improved-master/index.php on line 456
datafusion::physical_plan::joins - Rust
[go: Go Back, main page]
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
    Cross Join Execution Plan
  • HashJoinExec
    Join execution plan: Evaluates equijoin 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 that executes equi-join predicates on multiple partitions using Sort-Merge join algorithm and applies an optional filter post join. Can be used to join arbitrarily large inputs where one or both of the inputs don’t fit in the available memory.
  • 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§