blob: 0275b2d11d1f282e8130983967538bbc59d32175 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
|
(
(let mr_source (DataSource 'yt 'plato))
(let data (block '(
(let x (Read! world mr_source (Key '('table (String 'Input))) '('key 'subkey 'value) '()))
(let world (Left! x))
(let input (Right! x))
(let output (Sort input '((Bool 'true) (Bool 'true)) (lambda '(item) (block '(
(return '((Member item 'value) (Member item 'subkey)))
)))))
(return output)
)))
(let mr_sink (DataSink 'result))
(let world (Write! world mr_sink (Key) data '()))
(let world (Commit! world mr_sink))
(return world)
)
|
