This is an automated email from the ASF dual-hosted git repository.
wusheng pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/skywalking-banyandb.git
from b4412426 bump up modelcontextprotocol/sdk (#934)
add 904c5793 Implement element ID-based deduplication in stream query
results (#935)
No new revisions were added by this update.
Summary of changes:
CHANGES.md | 1 +
banyand/stream/query_by_idx.go | 18 +-
banyand/stream/query_by_idx_test.go | 190 +++
banyand/stream/query_by_ts.go | 11 +-
banyand/stream/query_by_ts_test.go | 266 ++++
.../logical/stream/stream_plan_indexscan_local.go | 9 +-
pkg/query/model/model.go | 15 +-
pkg/query/model/model_test.go | 249 ++++
pkg/test/stream/testdata/deduplication_test.json | 1452 +++++++++++++++++++
.../{duplicated.json => deduplication_test.json} | 8 +-
.../{duplicated.json => deduplication_test.json} | 4 +-
test/cases/init.go | 1 +
test/cases/stream/data/data.go | 73 +
...cated_all.ql => deduplication_test_limit_10.ql} | 3 +-
...d_all.yaml => deduplication_test_limit_10.yaml} | 3 +-
...ated_all.ql => deduplication_test_limit_100.ql} | 3 +-
..._all.yaml => deduplication_test_limit_100.yaml} | 3 +-
...cated_all.ql => deduplication_test_limit_25.ql} | 3 +-
...d_all.yaml => deduplication_test_limit_25.yaml} | 3 +-
...cated_all.ql => deduplication_test_limit_40.ql} | 3 +-
...d_all.yaml => deduplication_test_limit_40.yaml} | 3 +-
.../stream/data/testdata/deduplication_test.json | 1502 ++++++++++++++++++++
.../data/want/deduplication_test_limit_10.yaml | 277 ++++
.../data/want/deduplication_test_limit_100.yaml | 719 ++++++++++
.../data/want/deduplication_test_limit_25.yaml | 667 +++++++++
.../data/want/deduplication_test_limit_40.yaml | 719 ++++++++++
test/cases/stream/stream.go | 4 +
27 files changed, 6188 insertions(+), 21 deletions(-)
create mode 100644 banyand/stream/query_by_ts_test.go
create mode 100644 pkg/test/stream/testdata/deduplication_test.json
copy pkg/test/stream/testdata/index_rule_bindings/{duplicated.json =>
deduplication_test.json} (72%)
copy pkg/test/stream/testdata/streams/{duplicated.json =>
deduplication_test.json} (96%)
copy test/cases/stream/data/input/{duplicated_all.ql =>
deduplication_test_limit_10.ql} (93%)
copy test/cases/stream/data/input/{duplicated_all.yaml =>
deduplication_test_limit_10.yaml} (96%)
copy test/cases/stream/data/input/{duplicated_all.ql =>
deduplication_test_limit_100.ql} (93%)
copy test/cases/stream/data/input/{duplicated_all.yaml =>
deduplication_test_limit_100.yaml} (96%)
copy test/cases/stream/data/input/{duplicated_all.ql =>
deduplication_test_limit_25.ql} (93%)
copy test/cases/stream/data/input/{duplicated_all.yaml =>
deduplication_test_limit_25.yaml} (96%)
copy test/cases/stream/data/input/{duplicated_all.ql =>
deduplication_test_limit_40.ql} (93%)
copy test/cases/stream/data/input/{duplicated_all.yaml =>
deduplication_test_limit_40.yaml} (96%)
create mode 100644 test/cases/stream/data/testdata/deduplication_test.json
create mode 100644 test/cases/stream/data/want/deduplication_test_limit_10.yaml
create mode 100644
test/cases/stream/data/want/deduplication_test_limit_100.yaml
create mode 100644 test/cases/stream/data/want/deduplication_test_limit_25.yaml
create mode 100644 test/cases/stream/data/want/deduplication_test_limit_40.yaml
