93 Commits (main)

Author	SHA1	Message	Date
Trevor Whitney	030dd4418d	feat(dataobj-compactor): IndexMerge executor over postings + stats sections (#22233)	10 hours ago
benclive	e40777ea36	chore: Apply label hash sorting to topk when timestamps match (#22282)	10 hours ago
Ashwanth	d62c5906a9	chore(engine): Add stats for measuring data locality (#22271)	15 hours ago
Trevor Whitney	03cd8002cf	feat(dataobj/postings,stats): Add merge builders and row decoders (#22229)	2 days ago
Paul Rogers	5c0197c4f3	fix(dataobj): Handle constant predicates in logs predicate ordering (#22160)	3 days ago
benclive	2e3da9a59a	chore: Add better error message on predicate panic (#21935)	3 weeks ago
Shantanu Alshi	a2c48847a4	feat(dataobj): Implement sort schema (#21557)	3 weeks ago
Trevor Whitney	620bd56e0a	chore(compaction): Replace postings/stats RowReader with columnar Reader (#21785)	4 weeks ago
Trevor Whitney	96a0574783	feat(dataobj): Reduce postings indexing allocations via observe/aggregate pattern (#21610)	4 weeks ago
Trevor Whitney	deff86de61	feat: On-disk serialization for postings and stats index sections (#21591)	4 weeks ago
Christian Haudum	aaa2d1137a	chore: Remove unused/dead code (#21724) ... * chore(dataobj): Remove dead code * chore(engine): Remove unused code * chore(ci): Fix PR/commit title for Renovate (#21721) * fix: Incorrect impl of ProduceSync (#21702) * (origin/k304) docs: New usage statistics topic (#21668) * feat(lokitool): Rename `rules lint` to `rules format` (#21671) * chore: single binary without Kafka (#21318)	1 month ago
Trevor Whitney	8553815420	feat: add stats and postings index sections with encoding abstraction (#21442)	2 months ago
Dylan Guedes	bd7530f322	feat: Use `AppendOrdered` strategy to avoid sorting and merging stripes (#21395) ... Signed-off-by: Dylan Guedes <djmgguedes@gmail.com> Co-authored-by: George Robinson <george.robinson@grafana.com>	2 months ago
benclive	e9b4c8831b	chore: Reduce in-use zstd encoders for dataobj building (#21241)	2 months ago
benclive	968dabadd5	chore: Increase batch sizes for pointers reads (#20983)	3 months ago
Ashwanth	c24e1b27e8	chore: End index reader span on Close (#20854)	4 months ago
Robert Fratto	0437dabfb9	chore(metastore): fix metastore.indexSectionsReader Open semantics (#20835)	4 months ago
Ashwanth	73961f18a3	chore(xcap): leaner xcap API (#20771)	4 months ago
benclive	cd16b029db	chore: fix panic on read err in batchDecoratorReader (#20787)	4 months ago
Robert Fratto	d85fb0317f	chore(dataobj): Add Open semantics to section readers (#20790) ... Signed-off-by: Robert Fratto <robertfratto@gmail.com>	4 months ago
Robert Fratto	7e03400309	chore(dataobj): rename dataset.ReaderOptions to dataset.RowReaderOptions (#20756)	4 months ago
benclive	a029934ef2	chore: resolve predicate columns in distributed metastore (#20504)	4 months ago
Robert Fratto	9d9d8ce14d	chore(engine): introduce experimental expression engine (#20626)	4 months ago
Sandeep Sukhani	7f1450d8c5	feat(dataobj-compactor): add a planner for compaction of data objects (#20527)	4 months ago
Robert Fratto	736ccdbf93	chore(dataobj): rename dataset.Reader to RowReader (#20629)	4 months ago
Robert Fratto	747d75aa78	chore: make memory, columnar APIs more idiomatic (#20622)	4 months ago
Robert Fratto	08aaaa3754	chore(columnar): add scalars and builders (#20583)	4 months ago
Robert Fratto	3e3a293215	chore(columnar): switch to generic Number type (#20580)	4 months ago
Ivan Kalita	86f87e447c	chore(dataobj): use reader adapter (#20572) ... Continuation of #20525, I'm updating logs, pointers, streams readers to use reader adapter. Also adding binary support to arrowconv.	4 months ago
Ivan Kalita	aab681617b	chore(dataobj): add reader_adapter (#20525) ... Add a temporary translation layer []dataset.Row -> columnar.RecordBatch -> arrow.RecordBatch. - reader_adapter.go is temporary that's why I put it into the old columnar package - I added builders to reader_adapter.go and not to pkg/columnar.... as I'm not sure if we really would need them anywhere except for this adapter. If so I'm happy to move them to pkg/columnar. - I only updated indexpointers reader for now but will add support for more readers in the next PRs	4 months ago
yy	0574159216	chore: typos in comments (#20481)	5 months ago
Stas Spiridonov	c2116618bd	chore: Improving memory allocations for new query engine (#20321)	5 months ago
Ivan Kalita	e4ec8441d3	feat(metastore): use arrow for scanning and blooms (#20234) ... Changing metastore implementation to work with arrow.RecordBatch without intermediate materialization to structs. metastore.Sections now uses new metastore.GetIndexes, metastore.IndexSectionsReader and metastore.CollectSections. We'd like to run metastore queries in a distributed manner using engine v2. In order to achieve that we need to split the work that metastore.Sections does internally, schedule it on different workers, and collect the results. The engine achieves that via pipelines that produce arrow.RecordBatch-es. In this PR the metastore.Sections is updated such a way to make it easier to integrate metastore with the engine.	6 months ago
Ashwanth	7da7f000ff	chore: use projection for indexobj streams reader (#20205)	6 months ago
Ashwanth	54f9723af1	chore(xcap): adds exporter to summarise capture as a structured log line (#20099)	6 months ago
Ashwanth	728b308edf	chore: update read stats to use xcap (#20095)	6 months ago
Ivan Kalita	827292d8ed	chore(metastore): add columnar indexpointers reader (#20068) ... Similar to https://github.com/grafana/loki/pull/20053 and https://github.com/grafana/loki/pull/19992 I add a columnar reader for index pointers sections.	6 months ago
Ivan Kalita	ee58c333b3	chore(metastore): use column reader for blooms (#20053) ... This PR is a continuation of https://github.com/grafana/loki/pull/19992. I use `pointers.Reader` to refine the sections that match bloom filters. I also fix minor issues that I introduced in the previous PR: - convert the columns only once per column (instead of doing it for every row) - ignore the sections that are of a wrong "type"	6 months ago
Ivan Kalita	3559d4bd42	chore(metastore): add column reader for pointers section (#19992) ... Adding columnar reader for (log)pointers section. Using it to read the stream section pointers. New reader is slower than existing RowReader due to double-translation of the data (columns->rows->rows vs columns->rows->columns->rows). The idea though is to get rid of the double-translation in the future.	6 months ago
benclive	2ce207fbdb	chore: Use shared zstd encoders during dataobj build (#20044)	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>	7 months ago
Christian Haudum	73bc30d9a8	perf(engine): Improve regexp expression evaluation (#19644) ... This PR changes the evaluation of regex-match binary expression evaluations so that the regexp on right hand side of the expression is only compiled once for each batch evaluation, rather than for each row. This saves a ton of allocations and improves general performance of queries with a regexp line or label filter.	7 months ago
Ashwanth	5a06d44826	chore: table build fill all columns to max rows (#19614)	7 months ago
Stas Spiridonov	160dc2c493	chore: removed arrow-go allocators/retain/release (#19569)	8 months ago
Ashwanth	fa8bd848f6	chore: update buildTable to sort rows using `BuilderOptions.SortOrder` (#19515)	8 months ago
benclive	b0f5ca7f8c	chore: Dedup log objects during build (#19378)	8 months ago
Christian Haudum	386d4e1653	chore(dataobj): Make logs sort order in dataobjects configurable (#19373) ... This PR introduces a new configuration option `-dataobj-consumer.dataobj-sort-order` which controls the sort order of logs in the logs section of the dataobj when building new objects. There are two available sort options: 1. `timestamp DESC, streamID ASC` (configuration value `timestamp-desc`) 2. `streamID ASC, timestamp DESC` (configuration value `stream-asc`) The new setting is undocumented and may be removed in the future without notice. Signed-off-by: Christian Haudum <christian.haudum@gmail.com>	8 months ago
benclive	c5a0a3827d	chore: Memory improvements in dataobj page downloads (#19301)	8 months ago
benclive	2dac5ef8a7	chore: Write empty message values in logs section writer (#19359)	8 months ago
Christian Haudum	a3017f2b13	chore(dataobj-consumer): Sort logs object-wide (#19231) ... Sorting logs globally (object-wide per tenant) removes overlapping time ranges of sections in the objects. Sections contain logs from multiple streams, and the ingest lag of streams may vary. This means that although logs of individual sections are sorted by timestamp, the overall sorting of logs is not guaranteed. Therefore sections are sorted with a k-way merge (SortMerge), which does over-query data in case the query would reach its result limit early. Signed-off-by: Christian Haudum <christian.haudum@gmail.com>	9 months ago