summaryrefslogtreecommitdiff
path: root/config
diff options
context:
space:
mode:
authorwangkuan <[email protected]>2024-08-29 18:24:42 +0800
committerwangkuan <[email protected]>2024-08-29 18:24:42 +0800
commit0ea9b9d9db5f92e7afd7b86ddad1f8d69d5c0945 (patch)
treeca735cab001f5f3a597d87122cda0c998f3b9426 /config
parent8d90c04d22a5df3ac5a6d4d12fc1b9fee03f38e8 (diff)
[feature][bootstrap][core]增加预聚合功能,相关函数支持merge
Diffstat (limited to 'config')
-rw-r--r--config/grootstream_job_example.yaml1
1 files changed, 1 insertions, 0 deletions
diff --git a/config/grootstream_job_example.yaml b/config/grootstream_job_example.yaml
index b77958d..f5c6610 100644
--- a/config/grootstream_job_example.yaml
+++ b/config/grootstream_job_example.yaml
@@ -34,6 +34,7 @@ processing_pipelines:
window_timestamp_field: recv_time
window_size: 6
window_slide: 10 #滑动窗口步长
+ mini_batch: true
functions:
- function: NUMBER_SUM
lookup_fields: [ sent_pkts ]