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/25 15:12:48 UTC

[skywalking-banyandb] branch simple-streaming-api updated (942baff -> 66b6614)

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 942baff  remove timestamp flag and fix test
     add 66b6614  refactor flow API

No new revisions were added by this update.

Summary of changes:
 banyand/measure/measure_topn.go    | 24 +++++-------
 pkg/flow/{streaming => }/api/op.go | 23 ++++++++----
 pkg/flow/api/types.go              |  4 +-
 pkg/flow/batch/batch.go            | 13 +++----
 pkg/flow/batch/batch_filter.go     | 21 +++++++++--
 pkg/flow/batch/batch_test.go       |  2 +-
 pkg/flow/streaming/api/utils.go    | 76 --------------------------------------
 pkg/flow/streaming/flow_test.go    | 51 +++++--------------------
 pkg/flow/streaming/flow_unary.go   | 18 ++++-----
 9 files changed, 67 insertions(+), 165 deletions(-)
 rename pkg/flow/{streaming => }/api/op.go (67%)