blob: 08c7c997bcc755b749f3ced5da0f15b6ab55b0f0 (
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
27
|
(
(let mr_source (DataSource 'yt 'plato))
(let mr_sink (DataSink 'yt 'plato))
(let x (Read! world mr_source (Key '('table (String 'Input1))) (Void) '()))
(let world (Left! x))
(let data1 (Right! x))
(let x (Read! world mr_source (Key '('table (String 'Input2))) (Void) '()))
(let world (Left! x))
(let data2 (Right! x))
(let data (Mux '(data1 data2)))
(let data (Map data (lambda '(item) (block '(
(let res (Visit item
'0 (lambda '(x) x)
'1 (lambda '(x) x)
))
(return res)
)))))
(let world (Write! world mr_sink (Key '('table (String 'Output1))) data '('('mode 'renew))))
(let world (Commit! world mr_sink))
(return world)
)
|
