diff options
| author | doufenghu <[email protected]> | 2024-11-23 19:23:16 +0800 |
|---|---|---|
| committer | doufenghu <[email protected]> | 2024-11-23 19:23:16 +0800 |
| commit | 53d7c1778d15ff3dd9b4c411799455592990d03f (patch) | |
| tree | 3eee3117292f1c59a931a1a8314c67f3e9a1e5fa /groot-examples/end-to-end-example | |
| parent | 08015fd2e926aeb5019e1e2d96d4e23ab549346b (diff) | |
[Improve][e2e] Rename all e2e test modules to adapt to changes in the API operators.
Diffstat (limited to 'groot-examples/end-to-end-example')
| -rw-r--r-- | groot-examples/end-to-end-example/src/main/resources/examples/grootstream_job_split_test.yaml | 11 | ||||
| -rw-r--r-- | groot-examples/end-to-end-example/src/main/resources/examples/inline_to_print.yaml | 4 |
2 files changed, 7 insertions, 8 deletions
diff --git a/groot-examples/end-to-end-example/src/main/resources/examples/grootstream_job_split_test.yaml b/groot-examples/end-to-end-example/src/main/resources/examples/grootstream_job_split_test.yaml index 3477b00..852415e 100644 --- a/groot-examples/end-to-end-example/src/main/resources/examples/grootstream_job_split_test.yaml +++ b/groot-examples/end-to-end-example/src/main/resources/examples/grootstream_job_split_test.yaml @@ -18,18 +18,18 @@ splits: type: split rules: - tag: http_a_tag - expression: event.decoded_as == 'HTTP' + expression: decoded_as == 'HTTP' - tag: dns_a_tag - expression: event.decoded_as == 'DNS' + expression: decoded_as == 'DNS' test_split_b: type: split rules: - tag: base_b_tag - expression: event.decoded_as == 'BASE' + expression: decoded_as == 'BASE' - tag: dns_b_tag - expression: event.decoded_as == 'DNS' + expression: decoded_as == 'DNS' -postprocessing_pipelines: +processing_pipelines: pre_etl_processor: # [object] Processing Pipeline type: projection remove_fields: [fields,tags] @@ -103,7 +103,6 @@ application: # [object] Application Configuration - name: table_processor parallelism: 1 downstream: [ collect_sink ] - - name: collect_sink parallelism: 1 diff --git a/groot-examples/end-to-end-example/src/main/resources/examples/inline_to_print.yaml b/groot-examples/end-to-end-example/src/main/resources/examples/inline_to_print.yaml index 1e7c835..34b6e2a 100644 --- a/groot-examples/end-to-end-example/src/main/resources/examples/inline_to_print.yaml +++ b/groot-examples/end-to-end-example/src/main/resources/examples/inline_to_print.yaml @@ -10,7 +10,7 @@ filters: filter_operator: type: filter properties: - expression: event.server_ip != '12.12.12.12' + expression: server_ip != '12.12.12.12' processing_pipelines: projection_processor: @@ -18,7 +18,7 @@ processing_pipelines: remove_fields: [http_request_line, http_response_line, http_response_content_type] functions: - function: DROP - filter: event.server_ip == '4.4.4.4' + filter: server_ip == '4.4.4.4' sinks: print_sink: |