better naming

Signed-off-by: Richard Chien <[email protected]>
risingwavelabs · Feb 22, 2023 · 56ec2bf · 56ec2bf
1 parent 9442b6d
commit 56ec2bf
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 6 deletions.
diff --git a/src/stream/src/executor/aggregation/distinct.rs b/src/stream/src/executor/aggregation/distinct.rs
@@ -201,7 +201,7 @@ impl<S: StateStore> DistinctDeduplicater<S> {
         Self { deduplicaters }
     }
 
-    pub fn get_dedup_caches(&mut self) -> impl Iterator<Item = &mut DedupCache> {
+    pub fn dedup_caches_mut(&mut self) -> impl Iterator<Item = &mut DedupCache> {
         self.deduplicaters
             .values_mut()
             .map(|(_, deduplicater)| &mut deduplicater.cache)

diff --git a/src/stream/src/executor/global_simple_agg.rs b/src/stream/src/executor/global_simple_agg.rs
@@ -308,7 +308,7 @@ impl<S: StateStore> GlobalSimpleAggExecutor<S> {
             state_changed: false,
         };
 
-        vars.distinct_dedup.get_dedup_caches().for_each(|cache| {
+        vars.distinct_dedup.dedup_caches_mut().for_each(|cache| {
             cache.update_epoch(barrier.epoch.curr);
         });
 
@@ -340,7 +340,7 @@ impl<S: StateStore> GlobalSimpleAggExecutor<S> {
                     {
                         yield Message::Chunk(chunk);
                     }
-                    vars.distinct_dedup.get_dedup_caches().for_each(|cache| {
+                    vars.distinct_dedup.dedup_caches_mut().for_each(|cache| {
                         cache.update_epoch(barrier.epoch.curr);
                     });
                     yield Message::Barrier(barrier);

diff --git a/src/stream/src/executor/hash_agg.rs b/src/stream/src/executor/hash_agg.rs
@@ -558,7 +558,7 @@ impl<K: HashKey, S: StateStore> HashAggExecutor<K, S> {
             });
         this.result_table.init_epoch(barrier.epoch);
         vars.agg_group_cache.update_epoch(barrier.epoch.curr);
-        vars.distinct_dedup.get_dedup_caches().for_each(|cache| {
+        vars.distinct_dedup.dedup_caches_mut().for_each(|cache| {
             cache.update_epoch(barrier.epoch.curr);
         });
 
@@ -604,15 +604,15 @@ impl<K: HashKey, S: StateStore> HashAggExecutor<K, S> {
                         // Manipulate the cache if necessary.
                         if cache_may_stale(&previous_vnode_bitmap, &vnode_bitmap) {
                             vars.agg_group_cache.clear();
-                            vars.distinct_dedup.get_dedup_caches().for_each(|cache| {
+                            vars.distinct_dedup.dedup_caches_mut().for_each(|cache| {
                                 cache.clear();
                             });
                         }
                     }
 
                     // Update the current epoch.
                     vars.agg_group_cache.update_epoch(barrier.epoch.curr);
-                    vars.distinct_dedup.get_dedup_caches().for_each(|cache| {
+                    vars.distinct_dedup.dedup_caches_mut().for_each(|cache| {
                         cache.update_epoch(barrier.epoch.curr);
                     });