You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@skywalking.apache.org by lu...@apache.org on 2022/10/07 13:43:51 UTC
[skywalking-banyandb] branch simple-streaming-api updated (e858989 -> bc180cf)
This is an automated email from the ASF dual-hosted git repository.
lujiajing pushed a change to branch simple-streaming-api
in repository https://gitbox.apache.org/repos/asf/skywalking-banyandb.git
omit e858989 fix panic
omit 5a93e6f regenerate
omit 4ad2acb remove necessary data
omit 74f27cf remove duplicated writing
omit 95642cd add first test
omit 80b1857 add partial timeline impl
omit c7015e1 add test skeleton
omit 3413641 fix measure topn
omit 6a6612c fix lateness check
omit 8c7759f delete snapshot on purge
omit 89a32d1 refactor purge and polish API
omit 68e39d5 add streaming api and topN aggregator
add ae7fe81 Add indexed_only flag to tag spec (#182)
add 4bfbb84 Fix test cases with Eventually semantics (#183)
add e527405 add streaming api and topN aggregator
add 9c45d3a refactor purge and polish API
add 5e545ab delete snapshot on purge
add fdf5f37 fix lateness check
add 7039bd1 fix measure topn
add 4911b45 add test skeleton
add 0f4370a add partial timeline impl
add 8c02c09 add first test
add 8ed1bd3 remove necessary data
add fb59d5d regenerate
add bc180cf refactor post processor
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (e858989)
\
N -- N -- N refs/heads/simple-streaming-api (bc180cf)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
api/proto/banyandb/database/v1/schema.pb.go | 373 +++++++++++----------
.../banyandb/database/v1/schema.pb.validate.go | 2 +
api/proto/banyandb/database/v1/schema.proto | 4 +
.../openapi/banyandb/database/v1/rpc.swagger.json | 4 +
banyand/measure/measure_write.go | 20 +-
banyand/query/processor_topn.go | 65 ++--
banyand/stream/stream_write.go | 20 +-
docs/api-reference.md | 1 +
pkg/flow/dedup_priority_queue.go | 34 +-
pkg/flow/streaming/flow_sliding_window.go | 14 +-
pkg/pb/v1/metadata.go | 2 +-
pkg/pb/v1/write.go | 28 +-
pkg/test/stream/testdata/stream.json | 3 +-
test/cases/measure/data/data.go | 34 +-
test/cases/measure/measure.go | 7 +-
.../input/{global_index.yaml => indexed_only.yaml} | 8 +-
test/cases/stream/stream.go | 58 ++--
.../stream/want/{limit.yaml => indexed_only.yaml} | 26 +-
test/cases/topn/data/data.go | 20 +-
test/cases/topn/data/input/all.yaml | 3 +-
test/cases/topn/data/want/all.yaml | 7 +-
test/cases/topn/topn.go | 11 +-
test/integration/cold_query/query_suite_test.go | 52 +--
test/integration/other/measure_test.go | 38 ++-
test/integration/other/other_suite_test.go | 15 +-
test/integration/other/tls_test.go | 38 ++-
test/integration/query/query_suite_test.go | 26 +-
27 files changed, 497 insertions(+), 416 deletions(-)
copy test/cases/stream/input/{global_index.yaml => indexed_only.yaml} (90%)
copy test/cases/stream/want/{limit.yaml => indexed_only.yaml} (78%)