[skywalking-banyandb] branch simple-streaming-api updated (1beab92 -> 3af0e26)

[lu...@apache.org]

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 1beab92  Merge branch 'main' into simple-streaming-api
     add 0adda91  refactor TearDown
     add 3af0e26  fix check

No new revisions were added by this update.

Summary of changes:
 banyand/measure/measure_topn.go                    |  37 ++-
 pkg/flow/streaming/flow.go                         |  13 +
 pkg/flow/streaming/flow_sliding_window.go          |   8 +-
 pkg/flow/streaming/flow_sliding_window_test.go     | 109 +++----
 pkg/flow/streaming/flow_test.go                    | 313 ++++++++-------------
 pkg/flow/streaming/flow_unary.go                   |   5 +-
 pkg/flow/streaming/sink/slice.go                   |   6 +
 pkg/flow/streaming/sources/channel.go              |  24 +-
 pkg/flow/streaming/sources/channel_test.go         |   3 +-
 .../flow/streaming/streaming_suite_test.go         |   6 +-
 pkg/flow/types.go                                  |  11 +
 pkg/flow/utils.go                                  |   6 +-
 pkg/test/flow/slice.go                             |   4 +-
 13 files changed, 271 insertions(+), 274 deletions(-)
 copy bydbctl/internal/cmd/cmd_suite_test.go => pkg/flow/streaming/streaming_suite_test.go (91%)