blob: 6508146c9e70b17c7dd7c161065bf883cfab3ce7 (
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) (lambda '(item) (block '(
(return (Coalesce (FromString (Member item 'key) 'Double) (Double '0)))
)))))
(return output)
)))
(let mr_sink (DataSink 'result))
(let world (Write! world mr_sink (Key) data '()))
(let world (Commit! world mr_sink))
(return world)
)
|
