Module stream_hash_join

risingwave_frontend::optimizer::plan_node

Module stream_hash_join 

Source

Structs§

StreamHashJoin
StreamHashJoin implements super::LogicalJoin with hash table. It builds a hash table from inner (right-side) relation and probes with data from outer (left-side) relation to get output rows.
WatermarkDeriveResult 🔒
Result of watermark derivation for hash join.

Functions§

derive_watermark_for_hash_join 🔒
Derives watermark columns and state cleaning info for hash join.