blob: 4aa79168840e1d6f3f7bbf50c65edab0b1ff9f53 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
|
(
(let source (DataSource '"yt" '"plato"))
(let sink (DataSink '"yt" '"plato"))
(let r (Read! world source (Key '('table (String '"Input"))) (Void) '()))
(let world (Left! r))
(let input (Right! r))
(let sorted (Sort input (Bool 'true) (lambda '(item) (Member item '"key"))))
(let world (Write! world sink (Key '('table (String 'Output))) sorted '('('mode 'renew))))
(let world (Commit! world sink))
(let r (Read! world source (Key '('table (String '"Input"))) (Void) '()))
(let world (Left! r))
(let input (Right! r))
(let world (Write! world sink (Key '('table (String 'Output))) input '('('mode 'append))))
(let world (Commit! world sink))
(return world)
)
|
