update comment

Signed-off-by: TennyZhuang <[email protected]>
risingwavelabs · Feb 19, 2024 · 5b3bb5e · 5b3bb5e
1 parent d953993
commit 5b3bb5e
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/stream/src/executor/temporal_join.rs b/src/stream/src/executor/temporal_join.rs
@@ -117,8 +117,8 @@ struct TemporalSide<K: HashKey, S: StateStore> {
 }
 
 impl<K: HashKey, S: StateStore> TemporalSide<K, S> {
-    /// Lookup the temporal side table and return a `JoinEntry` which could be empty if there are no
-    /// matched records.
+    /// Fetch records from temporal side table and ensure the entry in the cache.
+    /// If already exists, the entry will be promoted.
     async fn fetch_or_promote_keys(
         &mut self,
         keys: impl Iterator<Item = &K>,