Skip to content

Commit 81b4d59

Browse files
perf(prefetch): enable prefetch for hash join with degree table (risingwavelabs#8566)
1 parent 7bd208d commit 81b4d59

File tree

1 file changed

+5
-2
lines changed
  • src/stream/src/executor/managed_state/join

1 file changed

+5
-2
lines changed

src/stream/src/executor/managed_state/join/mod.rs

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -365,11 +365,14 @@ impl<K: HashKey, S: StateStore> JoinHashMap<K, S> {
365365
let mut entry_state = JoinEntryState::default();
366366

367367
if self.need_degree_table {
368-
let table_iter_fut = self.state.table.iter_key_and_val(&key, Default::default());
368+
let table_iter_fut = self
369+
.state
370+
.table
371+
.iter_key_and_val(&key, PrefetchOptions::new_for_exhaust_iter());
369372
let degree_table_iter_fut = self
370373
.degree_state
371374
.table
372-
.iter_key_and_val(&key, Default::default());
375+
.iter_key_and_val(&key, PrefetchOptions::new_for_exhaust_iter());
373376

374377
let (table_iter, degree_table_iter) =
375378
try_join(table_iter_fut, degree_table_iter_fut).await?;

0 commit comments

Comments
 (0)