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/08/12 10:47:37 UTC
[skywalking-banyandb] branch simple-streaming-api updated (27314b3 -> 665cdfc)
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
discard 27314b3 change window impl
discard bc5ee95 fix data race
discard ce8fbf7 Merge branch 'main' into simple-streaming-api
discard 35ef53a refactor open api
discard a2fbaa7 fix test
discard 4fdb67e refactor flow error handling
discard 4d64af7 refactor timeTrigger and triggerContext
discard 51daca4 change Enum typing and change watermark strategy
discard c89b121 refactor flow API
discard 1e494d7 Merge branch 'main' into simple-streaming-api
discard ba73c54 rename pq
discard d6e86f9 try fix test
discard 35accc0 fix test
discard b0f3a32 fix race
discard cb92713 fix a panic
discard 32bcd23 polish topN close
discard 4a2b9fb fix test
discard 9f5371e fix check
discard 434f693 refactor TearDown
discard 3b0aef7 check chan Kind
discard 37786de add comments and refactor flow
discard c4e9118 add test for non-group-by TopN
discard e052723 remove batchApi
discard b262c08 refactor flow API
discard ac51e8f remove timestamp flag and fix test
discard 2420d3e fix lint
discard 4ded41f refactor storage layout
discard ee86422 fix test
discard a260777 fix format
discard 6e7fe6d fix imported
discard c0223fb fix measure overwrite and min and max aggregator
discard 3b9ac48 simplify AggregateFunction
discard e9ba8c2 add comment and remove api.Row shorthand
discard ecbb702 fix check
discard 66c3ee1 refactor storage layout
discard 6401548 add topN query
discard dbc8f69 support sort direction and json serialization
discard e864d52 use measureID as sharding key
discard ac7bd30 format
discard 79cc558 add test
discard d80867b support mapper and topN metadata reload
discard 083bc73 add measure topn
discard c6f7b13 add license
discard 386cae4 add batch api
discard 71b49ac refactor flow API
discard e0e506c add streaming api and topN aggregator
add 4391412 Update go 1.19 (#152)
add 05d858a Parameterize memory size and some key improvements (#153)
add 42c81ee Fix tsdb's leaked goroutines (#154)
add 2b8f41b add streaming api and topN aggregator
add cf17a68 refactor flow API
add 5a825fa add batch api
add cf10389 add license
add a9a5889 add measure topn
add 1a4eb2b support mapper and topN metadata reload
add 9532b1b add test
add bc57444 format
add 1a9a45b use measureID as sharding key
add 72d1b6b support sort direction and json serialization
add 323a536 add topN query
add 1fe0664 refactor storage layout
add 5fa8a86 fix check
add bc04162 add comment and remove api.Row shorthand
add 5cb6fbf simplify AggregateFunction
add df28e0a fix measure overwrite and min and max aggregator
add 9443d64 fix imported
add 4e06bfa fix format
add 3ef5723 fix test
add ff7ffb2 refactor storage layout
add 141484a fix lint
add 1d85d7f remove timestamp flag and fix test
add 72c8f74 refactor flow API
add 317899b remove batchApi
add fc66124 add test for non-group-by TopN
add bce5485 add comments and refactor flow
add 6199cef check chan Kind
add 1f06a4c refactor TearDown
add d847b24 fix check
add 6a11951 fix test
add cedc957 polish topN close
add 48e264d fix a panic
add b24dadb fix race
add bead3b6 fix test
add 67346b9 try fix test
add 57eb398 rename pq
add 0c9b6a6 refactor flow API
add b7c14f4 change Enum typing and change watermark strategy
add 49a3aae refactor timeTrigger and triggerContext
add 4eec9bd refactor flow error handling
add 314d427 fix test
add 39ec7af refactor open api
add a8b5221 fix data race
add 665cdfc change window impl
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 (27314b3)
\
N -- N -- N refs/heads/simple-streaming-api (665cdfc)
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:
.github/workflows/e2e.storage.yml | 2 +-
.github/workflows/go.yml | 6 +-
.github/workflows/publish-docker.yml | 2 +-
Makefile | 2 +-
api/proto/banyandb/measure/v1/topn.pb.go | 2 +-
api/proto/banyandb/measure/v1/write.pb.go | 2 +-
api/proto/banyandb/model/v1/common.pb.go | 2 +
banyand/Dockerfile | 4 +-
banyand/internal/cmd/root.go | 1 +
banyand/kv/kv.go | 29 ++++
banyand/measure/encode.go | 3 +-
banyand/measure/field_flag_test.go | 3 +-
banyand/measure/measure_write_test.go | 7 +-
banyand/measure/metadata.go | 28 ++--
banyand/measure/service.go | 9 +-
banyand/observability/metric.go | 3 +-
banyand/observability/type.go | 3 +-
banyand/query/processor_test.go | 4 +-
banyand/query/query_suite_test.go | 3 +-
banyand/stream/metadata.go | 26 ++--
banyand/stream/service.go | 13 +-
banyand/stream/stream.go | 9 +-
banyand/stream/stream_query_test.go | 4 +-
banyand/tsdb/block.go | 208 +++++++++++++++++---------
banyand/tsdb/bucket/bucket.go | 5 +-
banyand/tsdb/bucket/bucket_suite_test.go | 3 +-
banyand/tsdb/bucket/queue.go | 3 +-
banyand/tsdb/bucket/queue_test.go | 10 +-
banyand/tsdb/bucket/strategy.go | 103 +++++++------
banyand/tsdb/bucket/strategy_test.go | 18 ++-
banyand/tsdb/index/writer.go | 38 ++---
banyand/tsdb/metric.go | 5 +-
banyand/tsdb/scope.go | 3 +-
banyand/tsdb/segment.go | 88 ++++++-----
banyand/tsdb/series.go | 10 +-
banyand/tsdb/series_test.go | 3 +-
banyand/tsdb/seriesdb.go | 47 +++---
banyand/tsdb/shard.go | 20 ++-
banyand/tsdb/shard_test.go | 84 +++++++----
banyand/tsdb/tsdb.go | 33 ++--
banyand/tsdb/tsdb_suite_test.go | 5 +-
bydbctl/Dockerfile | 2 +-
bydbctl/cmd/bydbctl/main.go | 1 +
bydbctl/internal/cmd/root.go | 1 +
dist/LICENSE | 8 +-
go.mod | 38 +++--
go.sum | 14 +-
pkg/grpchelper/client.go | 3 +-
pkg/index/index.go | 22 ++-
pkg/index/lsm/lsm.go | 11 +-
pkg/query/aggregation/aggregation.go | 2 +-
pkg/query/aggregation/function.go | 2 +-
pkg/query/logical/common_test.go | 6 +-
pkg/query/logical/iter.go | 7 +-
pkg/query/logical/measure_plan_aggregation.go | 2 +-
pkg/query/logical/measure_plan_groupby.go | 3 +-
pkg/query/logical/measure_plan_top.go | 3 +-
pkg/query/logical/measure_top.go | 3 +-
pkg/query/logical/measure_top_test.go | 3 +-
pkg/query/logical/stream_analyzer.go | 5 +-
pkg/run/channel.go | 50 -------
pkg/run/run.go | 29 ++--
pkg/test/helpers/fail_interceptor.go | 8 +-
pkg/test/helpers/grpc_health.go | 3 +-
pkg/test/matcher.go | 3 +-
pkg/test/measure/traffic/traffic.go | 4 +-
pkg/test/space.go | 5 +-
pkg/test/stream/traffic/traffic.go | 10 +-
pkg/timestamp/clock.go | 5 +-
pkg/timestamp/duration.go | 2 +-
pkg/timestamp/duration_test.go | 3 +-
pkg/timestamp/nano.go | 3 +-
pkg/timestamp/nano_test.go | 3 +-
pkg/timestamp/range.go | 2 +-
scripts/build/lint-bin.mk | 2 +-
scripts/ci/check/version_test.go | 26 ++--
ui/embed.go | 1 +
77 files changed, 657 insertions(+), 491 deletions(-)
delete mode 100644 pkg/run/channel.go