We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
full
1 parent 199be83 commit 99d0363Copy full SHA for 99d0363
src/stream/src/executor/over_window/general.rs
@@ -171,9 +171,7 @@ impl<S: StateStore> OverWindowExecutor<S> {
171
.calls
172
.iter()
173
.any(|call| call.frame.bounds.is_unbounded());
174
- // TODO(rc): only support full cache for `RANGE` frame for now, for the sake of simplicity
175
- let has_range_frame = args.calls.iter().any(|call| call.frame.bounds.is_range());
176
- let cache_policy = if has_unbounded_frame || has_range_frame {
+ let cache_policy = if has_unbounded_frame {
177
// For unbounded frames, we finally need all entries of the partition in the cache,
178
// so for simplicity we just use full cache policy for these cases.
179
CachePolicy::Full
0 commit comments