diff options
| author | wangkuan <[email protected]> | 2024-11-26 18:13:48 +0800 |
|---|---|---|
| committer | wangkuan <[email protected]> | 2024-11-26 18:13:48 +0800 |
| commit | f2989ca998a3d164e53221625aa74c61585c0efa (patch) | |
| tree | a1cb40cd415eea9e14dc547a8df78c0704e707f3 /groot-bootstrap/src | |
| parent | 88d73bd9313e16d9738b84533f9ad17255e60b65 (diff) | |
[feature][core]CN-1730 回滚CollectList和CollectSet,新增数组聚合函数ArrayContactAgg及相关单元测试
Diffstat (limited to 'groot-bootstrap/src')
| -rw-r--r-- | groot-bootstrap/src/test/java/com/geedgenetworks/bootstrap/main/simple/JobAggTest.java | 2 | ||||
| -rw-r--r-- | groot-bootstrap/src/test/resources/grootstream_job_agg_test.yaml | 5 |
2 files changed, 4 insertions, 3 deletions
diff --git a/groot-bootstrap/src/test/java/com/geedgenetworks/bootstrap/main/simple/JobAggTest.java b/groot-bootstrap/src/test/java/com/geedgenetworks/bootstrap/main/simple/JobAggTest.java index 5945e51..779a8a5 100644 --- a/groot-bootstrap/src/test/java/com/geedgenetworks/bootstrap/main/simple/JobAggTest.java +++ b/groot-bootstrap/src/test/java/com/geedgenetworks/bootstrap/main/simple/JobAggTest.java @@ -73,7 +73,7 @@ public class JobAggTest { Set<String> set = (Set<String>) CollectSink.values.get(1).getExtractedFields().get("server_ip_set"); Set<String> set2 = (Set<String>) CollectSink.values.get(1).getExtractedFields().get("client_ips_set"); Assert.assertEquals(1, set.size()); - Assert.assertEquals(3, set2.size()); + Assert.assertEquals(2, set2.size()); Assert.assertEquals(2, list.size()); Assert.assertEquals("2", CollectSink.values.get(1).getExtractedFields().get("count").toString()); diff --git a/groot-bootstrap/src/test/resources/grootstream_job_agg_test.yaml b/groot-bootstrap/src/test/resources/grootstream_job_agg_test.yaml index 1ccaf3d..2633f6b 100644 --- a/groot-bootstrap/src/test/resources/grootstream_job_agg_test.yaml +++ b/groot-bootstrap/src/test/resources/grootstream_job_agg_test.yaml @@ -51,11 +51,12 @@ postprocessing_pipelines: - function: LAST_VALUE lookup_fields: [ log_id ] output_fields: [ log_id_last ] - - function: COLLECT_SET + - function: ARRAY_CONCAT_AGG lookup_fields: [ client_ips ] output_fields: [ client_ips_set ] parameters: - collect_type: array + mode: distinct + max_size: 2 application: # [object] Application Configuration env: # [object] Environment Variables name: groot-stream-job # [string] Job Name |