Module datafusion::physical_plan::joins::utils

Join related functionality used both on logical and physical plans

Structs

• ColumnIndex
  Information about the index and placement (left or right) of the columns
• JoinFilter
  Filter applied before join output
• JoinHashMap
  Maps a u64 hash value based on the build side [“on” values] to a list of indices with this key’s value.

Enums

• StatefulStreamResult
  Represents the result of a stateful operation.

Traits

• JoinHashMapType

Functions

• adjust_right_output_partitioning
  Adjust the right out partitioning to new Column Index
• build_join_schema
  Creates a schema for a join operation. The fields from the left side are first
• calculate_join_output_ordering
  Calculate the output ordering of a given join operation.
• check_join_is_valid
  Checks whether the schemas “left” and “right” and columns “on” represent a valid join. They are valid whenever their columns’ intersection equals the set on
• partitioned_join_output_partitioning
  Calculate the OutputPartitioning for Partitioned Join

Type Aliases

• JoinOn
  The on clause of the join, as vector of (left, right) columns.
• JoinOnRef
  Reference for JoinOn.