Skip to content

Commit

Permalink
update pipeline examples to version 2.0
Browse files Browse the repository at this point in the history
  • Loading branch information
lovromazgon committed Apr 3, 2023
1 parent cdfd4ca commit 90a67a7
Show file tree
Hide file tree
Showing 2 changed files with 9 additions and 9 deletions.
8 changes: 4 additions & 4 deletions examples/pipelines/file-to-file.yml
Original file line number Diff line number Diff line change
@@ -1,19 +1,19 @@
version: 1.0
version: 2.0
pipelines:
file-to-file:
- id: file-to-file
status: running
description: >
Example pipeline reading from file "example.in" and writing into file
"example.out". Note that the output file will contain the whole OpenCDC
record, the field "payload.after" will contain the base64 encoded line
written in "example.in".
connectors:
example.in:
- id: example.in
type: source
plugin: builtin:file
settings:
path: ./example.in
example.out:
- id: example.out
type: destination
plugin: builtin:file
settings:
Expand Down
10 changes: 5 additions & 5 deletions examples/processors/pipeline-extract-field-transform.yml
Original file line number Diff line number Diff line change
@@ -1,23 +1,23 @@
version: 1.0
version: 2.0
pipelines:
test-pipeline-builtin-processor:
- id: test-pipeline-builtin-processor
status: running
description: Test pipeline with built-in processor
connectors:
generator-source:
- id: generator-source
type: source
plugin: builtin:generator
settings:
format.type: "structured"
format.options: "id:int,name:string,company:string,trial:bool"
recordCount: "3"
file-destination:
- id: file-destination
type: destination
plugin: builtin:file
settings:
path: /file_destination.txt
processors:
extract-name:
- id: extract-name
type: extractfieldpayload
settings:
field: name

0 comments on commit 90a67a7

Please sign in to comment.