Like Prometheus, but for logs.
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
 
 
 
 
 
 
loki/pkg/engine/executor
Robert Fratto 5266865fef
chore(engine): add implementation for performing topk across streams of Arrow records (#18330)
6 months ago
..
arrow_scalar_compare.go chore(engine): add implementation for performing topk across streams of Arrow records (#18330) 6 months ago
dataobjscan.go chore(engine): Use shard information from query frontend in the new query engine (#17792) 7 months ago
dataobjscan_predicate.go chore(engine): Map line filter expressions to data object predicates (#18102) 7 months ago
dataobjscan_predicate_test.go chore(engine): Map line filter expressions to data object predicates (#18102) 7 months ago
dataobjscan_test.go chore(engine): Use shard information from query frontend in the new query engine (#17792) 7 months ago
executor.go chore(engine): Use shard information from query frontend in the new query engine (#17792) 7 months ago
executor_test.go chore(engine): provide basic implementation of DataObjScan (#17568) 8 months ago
expressions.go chore(engine): column expression evaluation for ambiguous column type look-ups (#18228) 6 months ago
expressions_test.go chore(engine): column expression evaluation for ambiguous column type look-ups (#18228) 6 months ago
filter.go chore(engine): Filter by unknown column (#18131) 7 months ago
filter_test.go chore(engine): Improve type system of the new query engine (#17456) 8 months ago
functions.go chore(engine): Add framework for function evaluation (#17374) 9 months ago
limit.go chore(engine): Use shard information from query frontend in the new query engine (#17792) 7 months ago
limit_test.go chore(dataobj,testing,executor): pipeline equality testing (#17311) 9 months ago
pipeline.go chore(engine): Add framework for query executor (#17260) 9 months ago
pipeline_test.go chore(engine): Collect pipeline records into Loki result (#17447) 9 months ago
pipeline_utils.go chore(engine): Collect pipeline records into Loki result (#17447) 9 months ago
pipeline_utils_test.go chore(engine): provide basic implementation of DataObjScan (#17568) 8 months ago
project.go chore(engine): Improve type system of the new query engine (#17456) 8 months ago
project_test.go chore(engine): Improve type system of the new query engine (#17456) 8 months ago
range_aggregation.go chore(engine): adds AST conversion and result builders for metric queries (#18166) 6 months ago
range_aggregation_test.go chore(engine): adds AST conversion and result builders for metric queries (#18166) 6 months ago
sortmerge.go fix(engine): Fix bug in `SortMerge` which caused rows to be skipped due to incorrect sorting (#18334) 6 months ago
sortmerge_test.go fix(engine): Fix bug in `SortMerge` which caused rows to be skipped due to incorrect sorting (#18334) 6 months ago
topk_batch.go chore(engine): add implementation for performing topk across streams of Arrow records (#18330) 6 months ago
topk_batch_test.go chore(engine): add implementation for performing topk across streams of Arrow records (#18330) 6 months ago
util_test.go fix(engine): Fix bug in `SortMerge` which caused rows to be skipped due to incorrect sorting (#18334) 6 months ago
vector_aggregate.go chore(engine): adds vector aggregation planning and execution nodes (#18100) 7 months ago
vector_aggregate_test.go chore(engine): adds vector aggregation planning and execution nodes (#18100) 7 months ago