Module stream 

Stream implementation for Hash Join

This module implements HashJoinStream, the streaming engine for super::HashJoinExec. See comments in HashJoinStream for more details.

Structs

BuildSideInitialState 🔒

Container for BuildSide::Initial related data

BuildSideReadyState 🔒

Container for BuildSide::Ready related data

HashJoinStream 🔒

[Stream] for super::HashJoinExec that does the actual join.

ProcessProbeBatchState 🔒

Container for HashJoinStreamState::ProcessProbeBatch related data

Enums

BuildSide 🔒

Represents build-side of hash join.

HashJoinStreamState 🔒

Represents state of HashJoinStream

Functions

lookup_join_hashmap 🔒

Executes lookups by hash against JoinHashMap and resolves potential hash collisions. Returns build/probe indices satisfying the equality condition, along with (optional) starting point for next iteration.