This is an automated email from the ASF dual-hosted git repository. lujiajing pushed a change to branch liaison-topology in repository https://gitbox.apache.org/repos/asf/skywalking-banyandb.git
from 1a7396b7 make lint happy add eecd29e7 chore: modify http server default flag (#325) add 95fe2180 Move clients and observebility docs to the bottom of menu (#327) add 5cee6c26 Distributed query (#326) add b034d20e Add Property CRUD Function (#328) add 6d2be584 Merge branch 'main' into liaison-topology No new revisions were added by this update. Summary of changes: CHANGES.md | 1 + api/proto/banyandb/cluster/v1/rpc.proto | 18 +- api/proto/banyandb/database/v1/database.proto | 3 +- banyand/dquery/dquery.go | 87 +++ banyand/dquery/measure.go | 100 ++++ banyand/dquery/stream.go | 84 +++ banyand/dquery/topn.go | 122 ++++ banyand/internal/cmd/liaison.go | 6 + banyand/liaison/http/server.go | 2 +- banyand/measure/measure.go | 38 +- banyand/measure/measure_write.go | 2 +- banyand/measure/metadata.go | 63 ++- banyand/measure/metadata_test.go | 10 +- banyand/measure/service.go | 6 +- banyand/query/processor.go | 15 +- banyand/queue/local.go | 8 + banyand/queue/pub/pub.go | 147 ++++- banyand/queue/queue.go | 1 + banyand/queue/sub/server.go | 2 +- banyand/queue/sub/sub.go | 56 +- banyand/stream/metadata.go | 65 ++- banyand/stream/metadata_test.go | 10 +- banyand/stream/service.go | 12 +- banyand/stream/stream.go | 34 +- docs/api-reference.md | 627 +++++++++++---------- docs/menu.yml | 8 +- pkg/bus/bus.go | 5 + pkg/iter/sort/sort.go | 133 +++++ pkg/iter/sort/sort_test.go | 102 ++++ pkg/query/executor/interface.go | 58 +- pkg/query/logical/common.go | 32 +- pkg/query/logical/index_filter.go | 14 +- pkg/query/logical/iter.go | 134 ----- pkg/query/logical/measure/measure_analyzer.go | 67 ++- pkg/query/logical/measure/measure_plan.go | 3 +- .../logical/measure/measure_plan_aggregation.go | 3 +- .../logical/measure/measure_plan_distributed.go | 234 ++++++++ pkg/query/logical/measure/measure_plan_groupby.go | 7 +- .../measure/measure_plan_indexscan_local.go | 18 +- pkg/query/logical/measure/measure_plan_top.go | 3 +- pkg/query/logical/stream/stream_analyzer.go | 28 +- .../logical/stream/stream_plan_distributed.go | 214 +++++++ .../logical/stream/stream_plan_indexscan_global.go | 11 +- .../logical/stream/stream_plan_indexscan_local.go | 11 +- pkg/query/logical/stream/stream_plan_tag_filter.go | 5 +- pkg/run/channel_closer.go | 2 +- pkg/schema/metadata.go | 364 ++++++------ pkg/schema/schema.go | 96 ++++ ui/src/api/index.js | 36 ++ ui/src/components/Aside/index.vue | 79 ++- ui/src/components/Editor/index.vue | 6 +- ui/src/components/IndexRule/Editor.vue | 4 +- ui/src/components/IndexRule/index.vue | 4 +- ui/src/components/IndexRuleBinding/Editor.vue | 4 +- ui/src/components/IndexRuleBinding/index.vue | 4 +- ui/src/components/MeasureEditor/index.vue | 6 +- ui/src/components/Property/PropertyEditror.vue | 230 ++++++++ ui/src/components/Property/PropertyRead.vue | 189 +++++++ ui/src/components/Property/TagEditor.vue | 95 ++++ ui/src/components/Read/index.vue | 6 +- ui/src/components/TopNav/index.vue | 50 +- ui/src/router/index.js | 18 +- ui/src/views/Property/index.vue | 40 +- 63 files changed, 2953 insertions(+), 889 deletions(-) create mode 100644 banyand/dquery/dquery.go create mode 100644 banyand/dquery/measure.go create mode 100644 banyand/dquery/stream.go create mode 100644 banyand/dquery/topn.go create mode 100644 pkg/iter/sort/sort.go create mode 100644 pkg/iter/sort/sort_test.go delete mode 100644 pkg/query/logical/iter.go create mode 100644 pkg/query/logical/measure/measure_plan_distributed.go create mode 100644 pkg/query/logical/stream/stream_plan_distributed.go create mode 100644 pkg/schema/schema.go create mode 100644 ui/src/components/Property/PropertyEditror.vue create mode 100644 ui/src/components/Property/PropertyRead.vue create mode 100644 ui/src/components/Property/TagEditor.vue