summaryrefslogtreecommitdiff
path: root/groot-examples
diff options
context:
space:
mode:
authordoufenghu <[email protected]>2024-11-23 19:23:16 +0800
committerdoufenghu <[email protected]>2024-11-23 19:23:16 +0800
commit53d7c1778d15ff3dd9b4c411799455592990d03f (patch)
tree3eee3117292f1c59a931a1a8314c67f3e9a1e5fa /groot-examples
parent08015fd2e926aeb5019e1e2d96d4e23ab549346b (diff)
[Improve][e2e] Rename all e2e test modules to adapt to changes in the API operators.
Diffstat (limited to 'groot-examples')
-rw-r--r--groot-examples/end-to-end-example/src/main/resources/examples/grootstream_job_split_test.yaml11
-rw-r--r--groot-examples/end-to-end-example/src/main/resources/examples/inline_to_print.yaml4
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: