diff options
| author | wangkuan <[email protected]> | 2024-08-01 18:22:54 +0800 |
|---|---|---|
| committer | wangkuan <[email protected]> | 2024-08-01 18:22:54 +0800 |
| commit | c0a2e18f14fd495d80e047b90e5afb0abcb9602c (patch) | |
| tree | 1848dacfa85d31ea1f5e3b7d6a923c43ce0715b1 /config/grootstream_job_example.yaml | |
| parent | 906a4a1bfe7d2dee5ed7144d20f05ba55546b02c (diff) | |
[improve][core]aggregate processor增加window_timestamp_field配置
Diffstat (limited to 'config/grootstream_job_example.yaml')
| -rw-r--r-- | config/grootstream_job_example.yaml | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/config/grootstream_job_example.yaml b/config/grootstream_job_example.yaml index 74239c9..4726af0 100644 --- a/config/grootstream_job_example.yaml +++ b/config/grootstream_job_example.yaml @@ -24,6 +24,7 @@ processing_pipelines: output_fields: group_by_fields: [server_ip,server_port] window_type: tumbling_processing_time # tumbling_event_time,sliding_processing_time,sliding_event_time + window_timestamp_field: recv_time window_size: 60 window_slide: 10 #滑动窗口步长 functions: |