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/07/26 01:46:41 UTC
[skywalking-banyandb] branch simple-streaming-api updated (66b6614 -> 52742fa)
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
from 66b6614 refactor flow API
add 52742fa remove batchApi
No new revisions were added by this update.
Summary of changes:
banyand/measure/measure_topn.go | 45 +++--
banyand/measure/measure_topn_test.go | 16 +-
banyand/query/processor_topn.go | 2 +-
banyand/query/processor_topn_test.go | 2 +-
pkg/flow/batch/api/types.go | 44 -----
pkg/flow/batch/batch.go | 180 --------------------
pkg/flow/batch/batch_filter.go | 172 -------------------
pkg/flow/batch/batch_test.go | 182 ---------------------
pkg/flow/batch/sink/slice.go | 48 ------
pkg/flow/batch/sources/series.go | 67 --------
pkg/flow/batch/testdata/measure_query_data.json | 92 -----------
pkg/flow/{api => }/ds.go | 2 +-
pkg/flow/{api => }/op.go | 2 +-
pkg/flow/{api => }/priority_queue_set.go | 2 +-
pkg/flow/streaming/flow.go | 104 ++++++------
pkg/flow/streaming/flow_sliding_window.go | 48 +++---
pkg/flow/streaming/flow_sliding_window_test.go | 16 +-
pkg/flow/streaming/flow_test.go | 70 ++++----
pkg/flow/streaming/flow_topn.go | 6 +-
pkg/flow/streaming/flow_topn_test.go | 32 ++--
pkg/flow/streaming/flow_unary.go | 29 ++--
pkg/flow/streaming/sources/channel_test.go | 6 +-
pkg/flow/streaming/sources/reader.go | 4 +-
pkg/flow/streaming/sources/reader_test.go | 6 +-
pkg/flow/streaming/sources/slice.go | 10 +-
pkg/flow/streaming/sources/slice_test.go | 6 +-
pkg/flow/{api => }/types.go | 8 +-
...json => service_cpm_minute_nogroup_top100.json} | 5 +-
28 files changed, 218 insertions(+), 988 deletions(-)
delete mode 100644 pkg/flow/batch/api/types.go
delete mode 100644 pkg/flow/batch/batch.go
delete mode 100644 pkg/flow/batch/batch_filter.go
delete mode 100644 pkg/flow/batch/batch_test.go
delete mode 100644 pkg/flow/batch/sink/slice.go
delete mode 100644 pkg/flow/batch/sources/series.go
delete mode 100644 pkg/flow/batch/testdata/measure_query_data.json
rename pkg/flow/{api => }/ds.go (98%)
rename pkg/flow/{api => }/op.go (99%)
rename pkg/flow/{api => }/priority_queue_set.go (99%)
rename pkg/flow/{api => }/types.go (92%)
copy pkg/test/measure/testdata/topn_aggregations/{service_cpm_minute_top100.json => service_cpm_minute_nogroup_top100.json} (70%)