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.

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

Type Aliases

JoinOn

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

JoinOnRef

Reference for JoinOn.