Module 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. Fields are crate-public to allow downstream implementations to experiment with custom joins.

Enums

StatefulStreamResult

Represents the result of a stateful operation.

Traits

JoinHashMapType

Maps a u64 hash value based on the build side [“on” values] to a list of indices with this key’s value.

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

compare_join_arrays

Get comparison result of two rows of join arrays

reorder_output_after_swap

When the order of the join inputs are changed, the output order of columns must remain the same.

swap_join_projection

This function swaps the given join’s projection.

update_hash

Updates hash_map with new entries from batch evaluated against the expressions on using offset as a start value for batch row indices.

Type Aliases

JoinOn

The on clause of the join, as vector of (left, right) columns.

JoinOnRef

Reference for JoinOn.