This is an automated email from the ASF dual-hosted git repository.
wusheng pushed a change to branch patch
in repository https://gitbox.apache.org/repos/asf/skywalking-banyandb.git
from fe6650a6 Stop check loop once the node is healthy
add 7dd1afa2 Return the tagValue of sorted tag (#465)
add 2f37a17c Improve sorting performance of Stream (#459)
add 568e96c9 [GsoC][BanyanDB] Self-Observability: Write Metric Data to
Measure In Standalone Mode (#467)
add 8bdb5318 Deduplicate data points in distributed query (#469)
add a69ec569 Fix the data node can't re-register to etcd (#471)
add e85aeb57 Fix several bugs (#473)
add ac930785 Merge branch 'main' into patch
No new revisions were added by this update.
Summary of changes:
CHANGES.md | 5 +
api/proto/banyandb/database/v1/schema.proto | 2 +
api/proto/banyandb/measure/v1/query.proto | 7 +-
banyand/internal/storage/index.go | 6 +-
banyand/internal/storage/segment.go | 40 +-
banyand/internal/storage/version.go | 28 +-
banyand/metadata/client.go | 2 +-
banyand/metadata/embeddedserver/server.go | 4 +-
banyand/metadata/schema/etcd.go | 125 ++++--
banyand/metadata/schema/etcd_test.go | 10 +-
banyand/metadata/schema/register_test.go | 35 +-
banyand/metadata/schema/watcher_test.go | 9 +-
banyand/observability/instrument.go | 38 +-
.../{meter_noop.go => meter_native.go} | 7 +
banyand/observability/meter_prom.go | 2 +
banyand/observability/metrics_system.go | 10 +-
banyand/observability/service.go | 44 +-
banyand/queue/pub/client.go | 10 +-
banyand/stream/benchmark_test.go | 6 +-
banyand/stream/block.go | 20 +-
banyand/stream/index.go | 47 ++-
banyand/stream/iter.go | 148 -------
banyand/stream/iter_builder.go | 124 ------
banyand/stream/part.go | 162 --------
banyand/stream/query.go | 455 +++++++++------------
banyand/stream/query_test.go | 114 +-----
banyand/stream/stream.go | 2 -
banyand/stream/tstable.go | 20 -
banyand/stream/write.go | 6 +-
bydbctl/internal/cmd/property.go | 4 +-
bydbctl/internal/cmd/property_test.go | 79 ++++
bydbctl/internal/cmd/root.go | 2 +-
docs/api-reference.md | 4 +-
pkg/cmdsetup/data.go | 2 +-
pkg/cmdsetup/liaison.go | 2 +-
pkg/cmdsetup/root.go | 4 +-
pkg/cmdsetup/standalone.go | 2 +-
pkg/index/index.go | 30 +-
pkg/index/inverted/inverted.go | 40 +-
pkg/index/inverted/sort.go | 9 +-
pkg/index/inverted/sort_test.go | 11 +-
pkg/index/testcases/duration.go | 3 +-
pkg/logger/logger.go | 11 +-
pkg/meter/native/collection.go | 108 +++++
pkg/meter/native/instruments.go | 41 +-
pkg/meter/native/provider.go | 62 ++-
pkg/meter/native/vec.go | 97 +++++
pkg/pb/v1/metadata.go | 14 +-
pkg/query/executor/interface.go | 2 -
pkg/query/logical/common.go | 1 +
.../logical/measure/measure_plan_distributed.go | 93 ++++-
.../measure/measure_plan_distributed_test.go | 160 ++++++++
.../measure/measure_plan_indexscan_local.go | 1 +
pkg/query/logical/plan.go | 3 +
.../logical/stream/stream_plan_indexscan_local.go | 82 +---
test/cases/measure/data/data.go | 2 +
56 files changed, 1263 insertions(+), 1094 deletions(-)
rename banyand/observability/{meter_noop.go => meter_native.go} (87%)
delete mode 100644 banyand/stream/iter.go
delete mode 100644 banyand/stream/iter_builder.go
create mode 100644 pkg/meter/native/collection.go
create mode 100644 pkg/meter/native/vec.go
create mode 100644 pkg/query/logical/measure/measure_plan_distributed_test.go
