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/02 14:06:58 UTC
[skywalking-banyandb] branch simple-streaming-api updated (559cf1c -> ce69548)
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 559cf1c Merge branch 'main' into simple-streaming-api
add ce69548 add batch api
No new revisions were added by this update.
Summary of changes:
banyand/measure/measure_query_test.go | 18 +-
banyand/measure/measure_write_test.go | 10 +-
banyand/stream/stream_query_test.go | 10 +-
banyand/stream/stream_write_test.go | 8 +-
banyand/tsdb/block.go | 6 +-
banyand/tsdb/series.go | 43 ++-
banyand/tsdb/series_filter.go | 278 ++++++++++++++++++
banyand/tsdb/series_filter_test.go | 315 +++++++++++++++++++++
banyand/tsdb/series_seek.go | 52 +++-
banyand/tsdb/series_seek_filter.go | 11 +-
banyand/tsdb/series_seek_sort.go | 59 ++--
banyand/tsdb/series_write.go | 4 +-
banyand/tsdb/seriesdb.go | 10 +-
pkg/flow/api/types.go | 3 +-
.../nano_test.go => flow/batch/api/types.go} | 33 ++-
pkg/flow/batch/batch.go | 183 ++++++++++++
pkg/flow/batch/batch_filter.go | 157 ++++++++++
.../common_test.go => flow/batch/batch_test.go} | 154 ++++------
pkg/{test/retry.go => flow/batch/sink/slice.go} | 40 +--
pkg/flow/batch/sources/series.go | 67 +++++
.../batch}/testdata/measure_query_data.json | 0
pkg/flow/streaming/flow.go | 8 +-
pkg/flow/streaming/flow_sliding_window.go | 56 ++--
pkg/flow/streaming/flow_test.go | 6 +-
pkg/flow/streaming/flow_topn.go | 18 +-
pkg/flow/streaming/flow_unary.go | 3 +-
pkg/flow/streaming/sources/slice.go | 3 +-
pkg/iter/iter.go | 109 +++++++
pkg/pb/v1/query.go | 55 ++++
pkg/query/logical/common.go | 6 +-
pkg/query/logical/expr.go | 4 +
pkg/query/logical/iter.go | 17 +-
pkg/query/logical/measure_plan_indexscan_local.go | 49 ++--
pkg/query/logical/stream_plan_indexscan_local.go | 8 +-
34 files changed, 1519 insertions(+), 284 deletions(-)
create mode 100644 banyand/tsdb/series_filter.go
create mode 100644 banyand/tsdb/series_filter_test.go
copy pkg/{timestamp/nano_test.go => flow/batch/api/types.go} (61%)
create mode 100644 pkg/flow/batch/batch.go
create mode 100644 pkg/flow/batch/batch_filter.go
copy pkg/{query/logical/common_test.go => flow/batch/batch_test.go} (60%)
copy pkg/{test/retry.go => flow/batch/sink/slice.go} (60%)
create mode 100644 pkg/flow/batch/sources/series.go
copy pkg/{query/logical => flow/batch}/testdata/measure_query_data.json (100%)
create mode 100644 pkg/iter/iter.go