97 Commits (v3.5.9)

Author	SHA1	Message	Date
George Robinson	1b8b5ddfa8	fix(release-3.5.x): bump Go version to 1.24.8 (#19454) (#19462) ... Co-authored-by: Sophie Waldman <sophie.waldman@grafana.com>	3 months ago
Robert Fratto	9be95a3e8c	chore(dataobj): reduce memory overhead of merging logs stripes (#16833)	10 months ago
Ashwanth	c51fa39684	chore(dataobj): pass down line filters to logs reader (#16802)	10 months ago
benclive	4befd22dd9	feat(dataobj-explorer): Add stream distribution info to dataobj explorer UI (#16525)	10 months ago
aarogoss	a57a80ea32	feat(metastore): Implement Labels() and Values() on ObjectMetastore (#16734)	10 months ago
Christian Haudum	9691f3e5dc	chore: Move `pkg/dataobj/planner` to `pkg/engine/planner` (#16815) ... The package pkg/dataobj/planner/logical was initially created within the package pkg/dataobj because of the dependency on the internal package pkg/dataobj/internal/metadatamd. However, the package should be located inside a separate package without the dependency on the dataobj package, since the engine should be storage agnostic. --- Signed-off-by: Christian Haudum <christian.haudum@gmail.com>	10 months ago
benclive	979f7614bc	perf: Optimization pass for reading from dataobjs (#16747)	10 months ago
Christian Haudum	f2257f5be0	chore: Implement the logical plan formatter using the generic tree printer (#16761) ... This PR implements the logical plan specific tree formatter using the generic tree printer introduced with https://github.com/grafana/loki/pull/16716 This solves the problem that expressions, which are properties of nodes, were treated equally as the nodes' child node. --- Signed-off-by: Christian Haudum <christian.haudum@gmail.com>	10 months ago
Christian Haudum	9bdd5d15bf	chore: Add tree printer for physical plan (#16716) ... This PR adds a generic tree printer (similar to the Unix utility `tree`). Additionally it provides an implementation to convert the DAG of the physical plan into the generic tree used by the tree printer. This allows to print plans like this (note, these examples do not make sense, they are only for demonstrating the visual output of the printer). Simple DAG with single child node: ``` Limit #limit offset=0 limit=0 └── Filter #filter predicates=() └── SortMerge #merge column=<nil> order=UNDEFINED ├── DataObjScan #scan1 location= stream_ids=() projections=() predicates=() direction=0 limit=0 └── DataObjScan #scan2 location= stream_ids=() projections=() predicates=() direction=0 limit=0 ``` DAG with multple root nodes: ``` Limit #limit1 offset=0 limit=0 └── DataObjScan #scan1 location= stream_ids=() projections=() predicates=() direction=0 limit=0 Limit #limit2 offset=0 limit=0 └── DataObjScan #scan2 location= stream_ids=() projections=() predicates=() direction=0 limit=0 ``` DAG with parent node that share the same child node: ``` Limit #limit offset=0 limit=0 ├── Limit #filter1 offset=0 limit=0 │ └── DataObjScan #scan location= stream_ids=() projections=() predicates=() direction=0 limit=0 └── Limit #filter2 offset=0 limit=0 └── DataObjScan #scan location= stream_ids=() projections=() predicates=() direction=0 limit=0 ``` --- Signed-off-by: Christian Haudum <christian.haudum@gmail.com>	10 months ago
Christian Haudum	5a76a04684	chore: Add basic building blocks of a physical plan (#16710) ... This PR adds the basic components of a physical plan. For the first iteration of the new execution engine, we need to support nodes to represent limited and filter queries (with only label/line filters). These nodes are: * DataObjScan * SortMerge * Projection * Filter * Limit The physical plan is implemented as a [directed acyclic graph](https://en.wikipedia.org/wiki/Directed_acyclic_graph) (DAG). It has convenience functions for adding nodes (vertices) and edges, getting parents and children of a node, as well as for traversing the graph using the [depth-first-search](https://en.wikipedia.org/wiki/Depth-first_search) algorithm. Additionally to the node types, the PR also contains the basic types of expressions, which can be properties of the nodes. --- Signed-off-by: Christian Haudum <christian.haudum@gmail.com>	10 months ago
Robert Fratto	cd11367148	chore(dataobj): Wire dataset.Reader into dataobj.LogsReader and dataobj.StreamsReader (#16701) ... Co-authored-by: Ashwanth Goli <iamashwanth@gmail.com>	10 months ago
Robert Fratto	8c4eb428c3	chore(dataobj): Download pages in 16MB batches (#16689)	10 months ago
Robert Fratto	abf3772366	perf(dataobj): improve parallelized read spead of Zstd (#16632)	10 months ago
benclive	91bab5e7f2	chore(metastore): Fix stream read condition (#16631)	10 months ago
Owen Diehl	89f0ed795f	feat(logical planning): Planner playground (#16403)	10 months ago
benclive	475d25f459	feat(metastore): Add initial interface for Metastore (#16604)	10 months ago
Paul Rogers	27431b7e7e	chore: Linting update for new golangci (#16572)	10 months ago
Robert Fratto	7f0dc01e21	chore(dataobj): introduce more efficient dataset reading (#16429) ... This commit introduces a new API, dataset.Reader, which scans through values in datasets more efficiently than dataset.Iter. As a result, dataset.Iter has been removed in favour of the new Reader. dataset.Reader is more efficient than dataset.Iter because: - It avoids using iter.Pull; the number of values flowing through coroutines added a significant amount of CPU overhead. - It supports efficient uses of predicates, where non-predicate columns are only loaded after finding matching rows from predicate columns; this avoids loading unnecessary pages. - It adds initial support for bulk page downloading, so that we need fewer roundtrips to object storage when iterating over a dataset. (This is not fully implemented yet; see below). - Early performance benchmarks see a ~3.4x speed improvement over reading 7GB of uncompressed logs, going from 192 MB/s (with dataset.Iter) to 652 MB/s (with dataset.Reader). This commit is truly massive, and to avoid it getting any larger, I'm leaving some follow up work to additional commits: - Updating dataobj.LogsReader and dataobj.StreamsReader to use the new API. - Adding support for downloading pages in batches; dataset.Reader will request multiple pages at once, but our decoder still unwraps that into several GET requests to object storage. Signed-off-by: Robert Fratto <robertfratto@gmail.com> Co-authored-by: Cyril Tovena <cyril.tovena@gmail.com>	10 months ago
Christian Haudum	f6fcc1194e	chore(dataobj): Decode values in batches (#16418) ... Signed-off-by: Christian Haudum <christian.haudum@gmail.com>	11 months ago
Jackson Coelho	290c14a8cb	chore: fix flush process for dataobj (#16393)	11 months ago
Trevor Whitney	5b16c0be7d	refactor: allow sample expressions to have multiple extractors (#16224)	11 months ago
Ashwanth	651d410eea	chore(dataobj): add "uncompressed size" column to streams section (#16322)	11 months ago
Owen Diehl	7d9414d032	feat(dataobj): expose cardinality estimations in UI (#16376)	11 months ago
Jackson Coelho	a2ba4bc181	chore: small fixes for #16348 (#16358)	11 months ago
Jackson Coelho	a51e5a21e2	chore: flush idle dataobjects after X seconds (#16348)	11 months ago
Cyril Tovena	543ad8e894	feat(dataobj-querier): Fixes streams section sharding & instrumentation (#16349)	11 months ago
Cyril Tovena	49bcaf47d7	feat(dataobj/querier): Add logging and improve stream processing metrics (#16325)	11 months ago
Cyril Tovena	dbf2befc1d	feat: Distributed Operational UI (#16097)	11 months ago
Cyril Tovena	fdbd66806a	chore(dataobj): Only stop reading from dataobj reader on EOF (#16274)	11 months ago
Cyril Tovena	78a141c6a9	feat(dataobj): Ensure constant sharding for the dataobj querier (#16273)	11 months ago
Cyril Tovena	8f69f0dbd4	feat(dataobj): Implement SelectLogs using a topk min-heap (#16261)	11 months ago
renovate[bot]	896bac0dab	chore(deps): update dependency @types/node to v22.13.3 (main) (#16263) ... Co-authored-by: renovate[bot] <29139614+renovate[bot]@users.noreply.github.com>	11 months ago
Cyril Tovena	13a6c33e32	feat(dataob): Implement SelectSamples (#16251) ... Signed-off-by: Cyril Tovena <cyril.tovena@gmail.com> Co-authored-by: Owen Diehl <ow.diehl@gmail.com>	11 months ago
renovate[bot]	1b1471dca0	chore(deps): update dependency @types/node to v22.13.2 (main) (#16257) ... Co-authored-by: renovate[bot] <29139614+renovate[bot]@users.noreply.github.com>	11 months ago
Owen Diehl	66889ec51d	feat(dataobj): cardinality estimation (#16233)	11 months ago
Cyril Tovena	5195296a17	fix(dataobj): Fixes timerange predicate (#16245)	11 months ago
Cyril Tovena	4bc95c0c68	feat(dataobj): Add methods for querying data objects metadata (#16190)	11 months ago
Cyril Tovena	5aa9e47d1c	fix(dataobj): Fixes timerange matching for dataobj files (#16222)	11 months ago
Robert Fratto	f87dd2ddf9	chore(dataobj): add predicate type for reading logs and streams (#16200)	11 months ago
Cyril Tovena	fa790e1ac8	feat(metastore): Implement listing data object for a given tenant and timerange (#16180)	11 months ago
renovate[bot]	cd7c625f6a	chore(deps): update dependency postcss to v8.5.2 (main) (#16172) ... Co-authored-by: renovate[bot] <29139614+renovate[bot]@users.noreply.github.com>	11 months ago
Owen Diehl	d9892b4481	fix(metastore): empty object corrections (#16147)	11 months ago
Robert Fratto	f71fc8afd3	chore(dataobj): pool instances of dataobj encoders (#16166)	11 months ago
benclive	656b1faaaf	fix(dataobj): Fix shutdown race in dataobj consumer (#16157)	11 months ago
benclive	52cb0af3aa	chore(dataobj): Use kgo Balancer for dataobj-consumer (#16146)	11 months ago
Cyril Tovena	1fa952dbf2	refactor(dataobj): Consolidate configuration and add querier support (#16144)	11 months ago
benclive	b7f6bb359b	chore(dataobj): Add iterator for metastores (#16114)	11 months ago
renovate[bot]	398c340b4f	chore(deps): update dependency vite to v6.1.0 (main) (#16108) ... Co-authored-by: renovate[bot] <29139614+renovate[bot]@users.noreply.github.com>	11 months ago
Robert Fratto	66b2721cfa	chore(dataobj): do not panic on unrecognized compression type (#16088)	11 months ago
benclive	7f32de6cf2	chore(dataobj): Refactor processor & builder to separate concerns (#16055)	11 months ago