blob: 46099b0328a3beaedd1fb3d77b19b10a4c1d7862 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
|
(
(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 'false) (lambda '(item) (Member item '"key"))))
(let world (Write! world sink (Key '('table (String 'Output))) sorted '('('mode 'append))))
(let world (Commit! world sink))
(return world)
)
|
