blob: 0ff086d5c750ad6b892a74731a172e905c1c63d5 (
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
25
26
27
28
29
|
(
(let world (block '(
(let x (Read! world (DataSource '"yt" '"plato") (Key '('table (String '"Input"))) (Void) '()))
(let world (Left! x))
(let table1 (Right! x))
(let table2 (Skip table1 (Uint32 '1)))
(let duplicate (lambda '(row) (block '(
(let res (Struct))
(let res (AsList row row))
(return res)
))))
(let ttable1 (FlatMap table1 duplicate))
(let ttable2 (FlatMap table2 duplicate))
(let extend (Extend ttable1 ttable2))
(let output (Filter extend (lambda '(row) (< (Member row '"key") (String '500)))))
(let world (block '(
(let result_sink (DataSink 'result))
(let world (Write! world result_sink (Key) output '('('type))))
(return (Commit! world result_sink))
)))
(return world)
)))
(let world (block '(
(let plato_sink (DataSink '"yt" '"plato"))
(let world (Commit! world plato_sink))
(return world)
)))
(return world)
)
|
