Skip to content

Commit a1de2bf

Browse files
committed
Add logger runner example #164
1 parent 65ef068 commit a1de2bf

2 files changed

Lines changed: 14 additions & 0 deletions

File tree

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,2 @@
1+
{ "hello" : "World" }
2+
{ "goodBye" : "World" }
Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,12 @@
1+
FLUX_DIR + "inputFile.json"
2+
| open-file
3+
| as-records
4+
| log-object(prefix="Before Transformation Object Log: ")
5+
| decode-json
6+
| log-stream(prefix="Before Transformation Stream Log: ")
7+
| fix("add_field('test','field')")
8+
| log-stream(prefix="After Transformation Stream Log: ")
9+
| encode-json
10+
| log-object(prefix="Output Object Log: ")
11+
| print
12+
;

0 commit comments

Comments
 (0)