@@ -49,28 +49,28 @@ In the fifth form, multiple sources are accessed in parallel and may be
4949
5050A pipeline can be split with the [ ` fork ` operator] ( fork.md ) as in
5151```
52- from PoolOne |> fork (
53- => op1 |> op2 | ...
54- => op1 |> op2 | ...
55- ) |> merge ts | ...
52+ from PoolOne | fork (
53+ => op1 | op2 | ...
54+ => op1 | op2 | ...
55+ ) | merge ts | ...
5656```
5757
5858Or multiple pools can be accessed and, for example, joined:
5959```
6060from (
61- pool PoolOne => op1 |> op2 | ...
62- pool PoolTwo => op1 |> op2 | ...
63- ) |> join on key=key | ...
61+ pool PoolOne => op1 | op2 | ...
62+ pool PoolTwo => op1 | op2 | ...
63+ ) | join on key=key | ...
6464```
6565
6666Similarly, data can be routed to different pipeline branches with replication
6767using the [ ` switch ` operator] ( switch.md ) :
6868```
69- from ... |> switch color (
70- case "red" => op1 |> op2 | ...
71- case "blue" => op1 |> op2 | ...
72- default => op1 |> op2 | ...
73- ) |> ...
69+ from ... | switch color (
70+ case "red" => op1 | op2 | ...
71+ case "blue" => op1 | op2 | ...
72+ default => op1 | op2 | ...
73+ ) | ...
7474```
7575
7676### Input Data
@@ -91,8 +91,8 @@ echo '{number:1,word:"one"} {number:2,word:"two"} {number:3,word:"three"}' |
9191 super db load -q -use numbers -
9292super db query -f text '
9393 from :branches
94- |> yield pool.name + "@" + branch.name
95- |> sort'
94+ | yield pool.name + "@" + branch.name
95+ | sort'
9696```
9797
9898The lake then contains the two pools:
@@ -114,7 +114,7 @@ The following file `hello.jsup` is also used.
114114_ Source structured data from a local file_
115115
116116``` mdtest-command
117- super -z -c 'file hello.jsup |> yield greeting'
117+ super -z -c 'file hello.jsup | yield greeting'
118118```
119119
120120``` mdtest-output
@@ -133,7 +133,7 @@ super -z -c 'file hello.jsup format line'
133133_ Source structured data from a URI_
134134```
135135super -z -c 'get https://raw.githubusercontent.com/brimdata/zui-insiders/main/package.json
136- |> yield productName'
136+ | yield productName'
137137```
138138=>
139139```
@@ -163,7 +163,7 @@ super db -lake example query -z 'from coinflips@trial'
163163
164164_ Count the number of values in the ` main ` branch of all pools_
165165``` mdtest-command
166- super db -lake example query -f text 'from * |> count()'
166+ super db -lake example query -f text 'from * | count()'
167167```
168168
169169``` mdtest-output
@@ -172,9 +172,9 @@ super db -lake example query -f text 'from * |> count()'
172172_ Join the data from multiple pools_
173173``` mdtest-command
174174super db -lake example query -z '
175- from coinflips |> sort flip
176- |> join (
177- from numbers |> sort number
175+ from coinflips | sort flip
176+ | join (
177+ from numbers | sort number
178178 ) on flip=number word'
179179```
180180
@@ -186,16 +186,16 @@ super db -lake example query -z '
186186_ Use ` pass ` to combine our join output with data from yet another source_
187187``` mdtest-command
188188super db -lake example query -z '
189- from coinflips |> sort flip
190- |> join (
191- from numbers |> sort number
189+ from coinflips | sort flip
190+ | join (
191+ from numbers | sort number
192192 ) on flip=number word
193- |> from (
193+ | from (
194194 pass
195195 pool coinflips@trial =>
196196 c:=count()
197- |> yield f"There were {int64(c)} flips"
198- ) |> sort this'
197+ | yield f"There were {int64(c)} flips"
198+ ) | sort this'
199199```
200200
201201``` mdtest-output
0 commit comments