File tree Expand file tree Collapse file tree 1 file changed +10
-0
lines changed Expand file tree Collapse file tree 1 file changed +10
-0
lines changed Original file line number Diff line number Diff line change @@ -24,6 +24,16 @@ static CACHE: LazyLock<DashMap<Key, Value>> = LazyLock::new(DashMap::default);
2424
2525/// Caches all the record batches in a global [CACHE] on the first run, and serves
2626/// them from the cache in any subsequent run.
27+ /// The order of events looks like this:
28+ /// 1. A first query is run.
29+ /// 2. Data is not cached, so it is gathered from the underlying node.
30+ /// 3. The cache is populated with the recently gathered data.
31+ /// 4. A second query is run.
32+ /// 5. The cache is hit, and data is returned from there.
33+ ///
34+ /// The cache key includes the result of "explaining" the underlying node, so different
35+ /// nodes applying different filters under the same parquet files will be cached
36+ /// independently.
2737#[ derive( Debug , Clone ) ]
2838pub struct InMemoryCacheExec {
2939 inner : Arc < dyn ExecutionPlan > ,
You can’t perform that action at this time.
0 commit comments