File tree Expand file tree Collapse file tree
asap-query-engine/src/engines/query_plan Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -5,12 +5,13 @@ debug-only for now: the existing executor remains the source of execution.
55
66Nodes are connected by ` n<id> ` inputs:
77
8- - ` StoreRead ` fetches one aggregation over its requested timestamp bounds.
9- - ` ComposeWindows ` turns stored buckets into one aggregate per output timestamp.
10- - ` ResolveKeys ` combines a value branch with an optional separate keys branch.
11- Without a keys branch, the value accumulator supplies its own keys.
12- - ` Estimate ` queries the accumulator statistic with its parameters.
13- - ` LimitTopK ` and ` Format ` are presentation nodes.
8+ - ` StoreRead ` — input: none; fetches one aggregation over its timestamp bounds.
9+ - ` ComposeWindows ` — input: one ` StoreRead ` ; composes buckets for each output timestamp.
10+ - ` ResolveKeys ` — inputs: a value composition and optional keys composition; resolves output keys.
11+ Without a keys input, the value accumulator supplies its own keys.
12+ - ` Estimate ` — input: ` ResolveKeys ` ; computes the requested statistic with its parameters.
13+ - ` LimitTopK ` — input: ` Estimate ` ; keeps the highest-ranked ` k ` candidates.
14+ - ` Format ` — input: ` Estimate ` or ` LimitTopK ` ; applies protocol-specific output labels.
1415
1516` StoreRead ` is either a tumbling grid scan or a sliding exact-cover scan. A
1617range plan has one read branch shared across all output timestamps. Binary
You can’t perform that action at this time.
0 commit comments