27 Commits (AISpellcheck)

Author	SHA1	Message	Date
Sandeep Sukhani	e74e2a20c5	fix: grouping by non-existent label in v2 query engine (#21430)	1 month ago
Stas Spiridonov	32248ef0ba	chore(thor): Performance optimization for aggregator (#20934)	3 months ago
Stas Spiridonov	0b483ab9c0	fix(thor): Fix for column duplicates in consequent compat stages (#20893)	3 months ago
Ashwanth	a56220f22f	chore(planner): apply parallelPushdown optimisation to valid aggregations (#20655)	3 months ago
Robert Fratto	00c8211fbf	chore(engine): add concurrency to Pipeline.Open (#20839)	3 months ago
Ashwanth	73961f18a3	chore(xcap): leaner xcap API (#20771)	3 months ago
Stas Spiridonov	b1f059d4e0	fix(thor): incorrect empty records skipping (#20812)	3 months ago
Robert Fratto	6a2c7c79e3	refactor(engine): introduce Pipeline.Open method (#20785)	3 months ago
Stas Spiridonov	514a142859	fix(thor): Fix error filtering before range aggregations (#20560)	4 months ago
Stas Spiridonov	efdb1f5a37	chore: Reducing waste on processing empty records (#20562)	4 months ago
Ashwanth	8b7161a9fc	chore(engine): enforce max_query_series (#20557)	4 months ago
Ashwanth	b21825ec23	chore: capture aggregation exec duration (#20299)	4 months ago
Stas Spiridonov	bedfb78378	chore: Thor query engine memory improvements, part 2 (#20473)	4 months ago
Stas Spiridonov	168da488db	fix: Out of bounds error fix for gapped window matcher (#20396)	4 months ago
Stas Spiridonov	c2116618bd	chore: Improving memory allocations for new query engine (#20321)	4 months ago
Stas Spiridonov	b6b7459435	chore: Aggregation groupings for by() and without() (#19928)	5 months ago
Ashwanth	11b1dcb2a3	chore(engine): introduce execution capture (#19821)	6 months ago
renovate-sh-app[bot]	d76b3bf495	fix(deps): update module github.com/apache/arrow-go/v18 to v18.4.1 (main) (#19750) ... Signed-off-by: renovate-sh-app[bot] <219655108+renovate-sh-app[bot]@users.noreply.github.com> Co-authored-by: renovate-sh-app[bot] <219655108+renovate-sh-app[bot]@users.noreply.github.com> Co-authored-by: Paul Rogers <paul.rogers@grafana.com>	6 months ago
Stas Spiridonov	7eda6749a4	feat(engine): basic math expressions (#19407)	7 months ago
Christian Haudum	9e76f1d251	chore(engine): Refactor `ColumnVector` (#19549) ... This PR removes the need of the ColumnVector as a result of expression evaluation and instead returns an arrow.Array. Signed-off-by: Christian Haudum <christian.haudum@gmail.com>	7 months ago
Stas Spiridonov	160dc2c493	chore: removed arrow-go allocators/retain/release (#19569)	7 months ago
Trevor Whitney	13429aa1ea	refactor: move allocator into execution Context (#19550)	7 months ago
Robert Fratto	cfd07c3683	chore(engine): simplify Pipeline interface (#19518)	7 months ago
Christian Haudum	849a9214fa	chore: Release column vectors and their arrays correctly (#19496) ... Signed-off-by: Christian Haudum <christian.haudum@gmail.com>	7 months ago
Stas Spiridonov	16dab82593	chore: consistent expressionEvaluator.eval result memory ownership (#19438)	7 months ago
Christian Haudum	119275aab7	chore(engine): Column naming conventions (#19396) ... In the new engine, we need fully qualified column names, since columns from different sources can have the same name. Right now, the distinction between columns with the same name is implemented using the `Metadata` field on the `arrow.Field`. However, it is quite cumbersome to parse the column type and data type from this generic map. This PR introduces package with naming conventions for columns, defined by name, data type, and column type. So, this information can be encoded into the `Name` field of the `arrow.Field`. The convention is defined as ``` [DATA_TYPE].[COLUMN_TYPE].[COLUMN_NAME] ``` #### Examples: * `utf8.label.service_name` * `timestamp_ns.builtin.timestamp` The column type can easily be converted into a `Scope`, which is defined by an origin and type. The mapping is as follows: ``` ColumnTypeBuiltin -> Scope{Record, Attribute} ColumnTypeMetadata -> Scope{Record, Builtin} ColumnTypeLabel -> Scope{Resource, Attribute} ColumnTypeParsed -> Scope{Generated, Attribute} ColumnTypeGenerated -> Scope{Generated, Builtin} ColumnTypeAmbiguous -> Scope{Unscoped, Attribute} ``` --- Signed-off-by: Christian Haudum <christian.haudum@gmail.com>	7 months ago
Robert Fratto	2e418b13fd	chore(engine): unexport subpackages (#19384) ... This moves packages around to reduce the surface area of the public engine API: * `pkg/engine/planner` moves to `pkg/engine/internal/planner` * `pkg/engine/executor` moves to `pkg/engine/internal/executor` These packages were only used from `pkg/engine` and did not need to be public. We may make them public again in the future if we want to expose subcomponents of the engine. This move means that `pkg/engine/planner/internal/tree` became `pkg/engine/internal/planner/internal/tree`. To reduce the import path, I also moved that package to `pkg/engine/internal/util/tree`. Other than moving files and updating import paths, no code changes are made. Signed-off-by: Robert Fratto <robertfratto@gmail.com>	7 months ago
Stas Spiridonov	1474ede675	feat(engine): More aggregations for the new query engine (#19350)	7 months ago
Christian Haudum	65de5f95db	chore(engine): Simplify `Pipeline` interface (#19110) ... This PR replaces the two calls to retrieve a value from the pipeline with a single one. To do this, the `Read()` method now returns two arguments: `arrow.Record` and `error`, rather than just the error. If the error is not `nil`, the first argument (arrow.Record) must be ignored by the caller. The `Value()` method is not needed any more and was removed. Signed-off-by: Christian Haudum <christian.haudum@gmail.com>	8 months ago
Ashwanth	d950d4075d	chore(engine): improve performance of matching window calculation (#19013) ... Currently range aggregation linearly scans through all the possible time windows (a 24h query with a 1m step results in 1440 windows) to find the matching ones. This is quite expensive as this matching is done for each row. This PR updates the matching code to use arithmetic which runs in constant time for cases where step >= range and for overlapping windows (step < range) it uses binary search. Co-authored-by: Ashwanth Goli <iamashwanth@gmail.com> Signed-off-by: Christian Haudum <christian.haudum@gmail.com>	8 months ago
Robert Fratto	2326bb0f4b	chore(engine): fix instances of double frees (#18915) ... Signed-off-by: Robert Fratto <robertfratto@gmail.com>	9 months ago
Ashwanth	827b1f2df4	chore(engine): add support for range metric queries (#18892)	9 months ago
Christian Haudum	cea56469b9	chore(engine): Pass context to Pipeline's Read() function (#18459) ... This change unifies how the request context is passed through the execution of pipelines. Instead of storing the context on pipelines, pass them as argument to the `Read()` function. This change alters the interface method of `Pipeline` from `Read() bool` to `Read(context.Context) bool`. Signed-off-by: Christian Haudum <christian.haudum@gmail.com>	10 months ago
Christian Haudum	4305a6aa61	chore(engine): Make literals simple types (#17733) ... Representing data types as simple types (string, int64, float64) makes them more efficient to cast without conversion. Signed-off-by: Christian Haudum <christian.haudum@gmail.com>	10 months ago
Ashwanth	646ebe81d8	chore(engine): adds AST conversion and result builders for metric queries (#18166)	11 months ago
Ashwanth	635896dab9	chore(engine): adds vector aggregation planning and execution nodes (#18100)	11 months ago
Ashwanth	1effa30851	chore(engine): implement range aggregation operator (#17997)	11 months ago