risingwave_stream::executor::join

Module hash_join

source

Structsยง

Enumsยง

Functionsยง

  • fetch_degrees ๐Ÿ”’
    We use this to fetch ALL degrees into memory. We use this instead of a streaming interface. It is necessary because we must update the degree_state_table concurrently. If we obtain the degrees in a stream, we will need to hold an immutable reference to the state table for the entire lifetime, preventing us from concurrently updating the state table.
  • into_stream ๐Ÿ”’
  • update_degree ๐Ÿ”’

Type Aliasesยง