blob: b17c4f3bef6b2c6e57d8710d6f153501219eb198 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
|
(
(let config (DataSource 'config))
(let world (Configure! world config '"OptimizerFlags" '"ExpandLMapOrShuffleByKeysViaBlock"))
(let input (AsList
(Int32 '1)
(Int32 '2)
(Int32 '3)
(Int32 '4)
))
(let lmap1 (LMap input (lambda '(stream)
(Map stream (lambda '(item) (+ item (Int32 '1))))
)))
(let lmap2 (LMap input (lambda '(stream)
(Map stream (lambda '(item) (* item (Int32 '2))))
)))
(let output (ZipAll lmap1 lmap2))
(let res_sink (DataSink 'result))
(let world (Write! world res_sink (Key) output '('('type))))
(let world (Commit! world res_sink))
(return world)
)
|
