Modulesยง
- absent ๐
- empty_
metric ๐ - histogram_
fold ๐ - instant_
manipulate ๐ - normalize ๐
- planner ๐
- range_
manipulate ๐ - scalar_
calculate ๐ - series_
divide ๐ - union_
distinct_ ๐on
Structsยง
- Absent
- Absent
Exec - Absent
Stream - Empty
Metric - Empty source plan that generate record batch with two columns:
- Empty
Metric Exec - Empty
Metric Stream - Histogram
Fold HistogramFoldwill fold the conventional (non-native) histogram (1) for later computing.- Histogram
Fold Exec - Histogram
Fold Stream - Instant
Manipulate - Manipulate the input record batch to make it suitable for Instant Operator.
- Instant
Manipulate Exec - Instant
Manipulate Stream - Prom
Extension Planner - Range
Manipulate - Time series manipulator for range function.
- Range
Manipulate Exec - Range
Manipulate Stream - Scalar
Calculate ScalarCalculateis the custom logical plan to calculatescalarin PromQL, return NaN when have multiple time series.- Series
Divide - Series
Divide Exec - Series
Divide Stream - Assume the input stream is ordered on the tag columns.
- Series
Normalize - Normalize the input record batch. Notice that for simplicity, this method assumes the input batch only contains sample points from one time series.
- Series
Normalize Exec - Series
Normalize Stream - Union
Distinct On - A special kind of
UNION(ORin PromQL) operator, for PromQL specific use case. - Union
Distinct OnExec - Union
Distinct OnStream
Constantsยง
- METRIC_
NUM_ ๐SERIES
Functionsยง
- build_
special_ time_ expr - resolve_
column_ name - Convert index back to column name for deserialization
- resolve_
column_ names - Batch process multiple column indices
- serialize_
column_ index - Utilities for handling unfix logic in extension plans Convert column name to index for serialization