blob: 3fbb12f446813b891cdc3acaa7c1b38df4bd9a99 (
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
|
(
(let source (DataSource 'yt 'plato))
(let sink (DataSink 'yt 'plato))
(let result (DataSink 'result))
(let r (Read! world source (MrTableConcat (Key '('table (String '"Input")))) (Void) '()))
(let input (Right! r))
(let world (Left! r))
(let out (Sort (FlatMap input (lambda '(item) (AsList item))) (Bool 'false) (lambda '(item) (Member item '"key"))))
(let world (Write! world sink (Key '('table (String '"Output"))) out '('('mode 'renew))))
(let world (Commit! world sink))
(let r (Read! world source (MrTableConcat (Key '('table (String '"Output")))) (Void) '()))
(let input (Right! r))
(let world (Left! r))
(let out (Sort (FlatMap input (lambda '(item) (AsList item))) (Bool 'true) (lambda '(item) (Member item '"key"))))
(let world (Write! world result (Key) out '('('type) '('autoref))))
(let world (Commit! world result))
(let world (Commit! world sink))
(return world)
)
|
