Structs§
- CREATE_
PHYSICAL_ ELAPSED - EXEC_
PLAN_ ELAPSED - MERGE_
SCAN_ ERRORS_ TOTAL - MERGE_
SCAN_ POLL_ ELAPSED - MERGE_
SCAN_ REGIONS - OPTIMIZE_
LOGICAL_ ELAPSED - OPTIMIZE_
PHYSICAL_ ELAPSED - OnDone
- A stream to call the callback once a RecordBatch stream is done.
- PARSE_
PROMQL_ ELAPSED - PARSE_
SQL_ ELAPSED - PUSH_
DOWN_ FALLBACK_ ERRORS_ TOTAL - QUERY_
MEMORY_ POOL_ REJECTED_ TOTAL - QUERY_
MEMORY_ POOL_ USAGE_ BYTES - QUERY_
STAGE_ ELAPSED - Timer of different stages in query.
- Region
Watermark Metrics Stream
Enums§
- Merge
State 🔒 - Intermediate merge state for one participating region while collecting terminal correctness watermarks across merge-scan sub-stages.
Functions§
- collect_
region_ 🔒watermarks - finalize_
region_ 🔒watermarks - maybe_
attach_ region_ watermark_ metrics - Attaches terminal region watermark metrics to
streamwhen collection is requested. - merge_
merge_ 🔒scan_ region_ watermarks - merge_
region_ 🔒watermark_ entries - Merge a batch of per-region watermark entries into the global merged state.
- should_
collect_ region_ watermark_ from_ query_ ctx - Returns whether terminal region watermark metrics should be collected for the query context.
- terminal_
recordbatch_ metrics_ from_ plan - terminal_
recordbatch_ metrics_ from_ plan_ if_ requested - Collects terminal record-batch metrics from
planonly when requested.