Skip to content

Commit

Permalink
minor
Browse files Browse the repository at this point in the history
Signed-off-by: Richard Chien <[email protected]>
  • Loading branch information
stdrc committed Apr 6, 2023
1 parent 3da1a07 commit b0f107e
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions src/stream/src/common/cache/state_cache.rs
Original file line number Diff line number Diff line change
Expand Up @@ -60,7 +60,7 @@ pub trait StateCacheFiller {
/// Get the capacity of the cache.
fn capacity(&self) -> Option<usize>;

/// Append an entry to the cache. The key is expected to be larger than all existing keys.
/// Insert an entry into the cache without cache validity check.
fn insert_unchecked(&mut self, key: Self::Key, value: Self::Value);

/// Finish syncing the cache with the state table. This should mark the cache as synced.
Expand All @@ -84,7 +84,7 @@ impl<K: Ord, V> TopNStateCache<K, V> {
}
}

pub fn new_with_row_count(capacity: usize, table_row_count: usize) -> Self {
pub fn with_table_row_count(capacity: usize, table_row_count: usize) -> Self {
Self {
table_row_count: Some(table_row_count),
cache: TopNCache::new(capacity),
Expand Down

0 comments on commit b0f107e

Please sign in to comment.