This is an automated email from the ASF dual-hosted git repository.
hanahmily pushed a change to branch query-criteria
in repository https://gitbox.apache.org/repos/asf/skywalking-banyandb.git
from eb2f074 Need to be squahsed
add a2ae5b4 Polish stream query
No new revisions were added by this update.
Summary of changes:
Makefile | 2 +-
banyand/query/processor.go | 104 +-
banyand/query/processor_test.go | 415 --------
banyand/query/query_suite_test.go | 134 ---
banyand/query/testdata/global_index.json | 64 --
banyand/query/testdata/multiple_shards.json | 64 --
banyand/stream/stream_query_test.go | 1014 --------------------
banyand/stream/stream_write_test.go | 294 ------
banyand/stream/testdata/global_index.json | 64 --
banyand/tsdb/series_seek_filter.go | 3 +
banyand/tsdb/seriesdb.go | 35 +
go.mod | 1 +
go.sum | 1 +
pkg/index/inverted/inverted.go | 14 +-
pkg/pb/v1/query.go | 369 -------
pkg/query/logical/common.go | 71 +-
pkg/query/logical/expr.go | 165 +---
pkg/query/logical/format.go | 2 +-
pkg/query/logical/index_filter.go | 164 ++--
.../logical/{ => measure}/measure_analyzer.go | 30 +-
.../logical/{ => measure}/measure_analyzer_test.go | 4 +-
pkg/query/logical/{ => measure}/measure_plan.go | 2 +-
.../{ => measure}/measure_plan_aggregation.go | 8 +-
.../{ => measure}/measure_plan_execution_test.go | 12 +-
.../logical/{ => measure}/measure_plan_groupby.go | 4 +-
.../{ => measure}/measure_plan_indexscan_local.go | 24 +-
.../logical/{ => measure}/measure_plan_top.go | 2 +-
pkg/query/logical/{ => measure}/measure_top.go | 2 +-
.../logical/{ => measure}/measure_top_test.go | 2 +-
pkg/query/logical/measure/schema.go | 104 ++
pkg/query/logical/plan_orderby.go | 38 +-
pkg/query/logical/schema.go | 240 +----
pkg/query/logical/stream/schema.go | 99 ++
pkg/query/logical/{ => stream}/stream_analyzer.go | 64 +-
pkg/query/logical/{ => stream}/stream_plan.go | 39 +-
.../{ => stream}/stream_plan_indexscan_global.go | 23 +-
.../{ => stream}/stream_plan_indexscan_local.go | 39 +-
.../logical/{ => stream}/stream_plan_tag_filter.go | 70 +-
pkg/query/logical/stream_analyzer_test.go | 314 ------
pkg/query/logical/stream_plan_execution_test.go | 407 --------
pkg/query/logical/tag_filter.go | 76 +-
pkg/test/helpers/context.go | 12 +
test/cases/stream/input/all.yaml | 9 +
test/cases/stream/input/global_index.yaml | 16 +
test/cases/stream/input/having.yaml | 16 +
test/cases/stream/input/less.yaml | 16 +
test/cases/stream/input/less_eq.yaml | 16 +
test/cases/stream/input/limit.yaml | 10 +
test/cases/stream/input/logical.yaml | 36 +
test/cases/stream/input/offset.yaml | 10 +
test/cases/stream/input/search.yaml | 16 +
test/cases/stream/input/sort_desc.yaml | 12 +
test/cases/stream/stream.go | 181 ++++
.../cases/stream/testdata/data.json | 16 +-
test/cases/stream/want/all.yaml | 66 ++
test/cases/stream/want/global_index.yaml | 14 +
test/cases/stream/want/having.yaml | 41 +
test/cases/stream/want/less.yaml | 53 +
test/cases/stream/want/less_eq.yaml | 69 ++
test/cases/stream/want/limit.yaml | 40 +
test/cases/stream/want/logical.yaml | 52 +
test/cases/stream/want/offset.yaml | 27 +
test/cases/stream/want/search.yaml | 35 +
test/cases/stream/want/sort_desc.yaml | 87 ++
test/integration/integration_suite_test.go | 144 +++
test/stress/stress_suite_test.go | 4 +-
66 files changed, 1702 insertions(+), 3879 deletions(-)
delete mode 100644 banyand/query/processor_test.go
delete mode 100644 banyand/query/query_suite_test.go
delete mode 100644 banyand/query/testdata/global_index.json
delete mode 100644 banyand/query/testdata/multiple_shards.json
delete mode 100644 banyand/stream/stream_query_test.go
delete mode 100644 banyand/stream/stream_write_test.go
delete mode 100644 banyand/stream/testdata/global_index.json
delete mode 100644 pkg/pb/v1/query.go
rename pkg/query/logical/{ => measure}/measure_analyzer.go (91%)
rename pkg/query/logical/{ => measure}/measure_analyzer_test.go (99%)
rename pkg/query/logical/{ => measure}/measure_plan.go (99%)
rename pkg/query/logical/{ => measure}/measure_plan_aggregation.go (97%)
rename pkg/query/logical/{ => measure}/measure_plan_execution_test.go (97%)
rename pkg/query/logical/{ => measure}/measure_plan_groupby.go (99%)
rename pkg/query/logical/{ => measure}/measure_plan_indexscan_local.go (95%)
rename pkg/query/logical/{ => measure}/measure_plan_top.go (99%)
rename pkg/query/logical/{ => measure}/measure_top.go (99%)
rename pkg/query/logical/{ => measure}/measure_top_test.go (98%)
create mode 100644 pkg/query/logical/measure/schema.go
create mode 100644 pkg/query/logical/stream/schema.go
rename pkg/query/logical/{ => stream}/stream_analyzer.go (71%)
rename pkg/query/logical/{ => stream}/stream_plan.go (70%)
rename pkg/query/logical/{ => stream}/stream_plan_indexscan_global.go (86%)
rename pkg/query/logical/{ => stream}/stream_plan_indexscan_local.go (77%)
rename pkg/query/logical/{ => stream}/stream_plan_tag_filter.go (70%)
delete mode 100644 pkg/query/logical/stream_analyzer_test.go
delete mode 100644 pkg/query/logical/stream_plan_execution_test.go
create mode 100644 pkg/test/helpers/context.go
create mode 100644 test/cases/stream/input/all.yaml
create mode 100644 test/cases/stream/input/global_index.yaml
create mode 100644 test/cases/stream/input/having.yaml
create mode 100644 test/cases/stream/input/less.yaml
create mode 100644 test/cases/stream/input/less_eq.yaml
create mode 100644 test/cases/stream/input/limit.yaml
create mode 100644 test/cases/stream/input/logical.yaml
create mode 100644 test/cases/stream/input/offset.yaml
create mode 100644 test/cases/stream/input/search.yaml
create mode 100644 test/cases/stream/input/sort_desc.yaml
create mode 100644 test/cases/stream/stream.go
rename banyand/stream/testdata/multiple_shards.json =>
test/cases/stream/testdata/data.json (85%)
create mode 100644 test/cases/stream/want/all.yaml
create mode 100644 test/cases/stream/want/global_index.yaml
create mode 100644 test/cases/stream/want/having.yaml
create mode 100644 test/cases/stream/want/less.yaml
create mode 100644 test/cases/stream/want/less_eq.yaml
create mode 100644 test/cases/stream/want/limit.yaml
create mode 100644 test/cases/stream/want/logical.yaml
create mode 100644 test/cases/stream/want/offset.yaml
create mode 100644 test/cases/stream/want/search.yaml
create mode 100644 test/cases/stream/want/sort_desc.yaml
create mode 100644 test/integration/integration_suite_test.go
