blob: d2aee30dd8c13d5b69bfef7a77449dfc7af5ab37 (
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
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
|
(
(let world (block '(
(let values (block '(
(let values (Struct))
(let values (AddMember values '"key" ("Just" (Cast ("Minus" (Int64 '"1")) 'Int32))))
(let values (AddMember values '"x" (String '"2")))
(return (AsList values))
)))
(let world (block '(
(let sink (DataSink '"yt" '"plato"))
(let world (Write! world sink (Key '('table (String '"Output"))) values '('('mode 'append))))
(return (Commit! world sink))
)))
(return world)
)))
(let world (block '(
(let x (Read! world (DataSource '"yt" '"plato") (Key '('table (String '"Output"))) '('"key") '()))
(let world (Left! x))
(let table0 (Right! x))
(let output (block '(
(let select (block '(
(let core table0)
(let core (block '(
(return (Aggregate core '('"key") '()))
)))
(let core (FlatMap core (lambda '(row) (block '(
(let res (Struct))
(let res (AddMember res '"column0" ("ToString" ("Coalesce" (Member row '"key") (Int64 '"34")))))
(let res (AsList res))
(return res)
)))))
(return core)
)))
(return select)
)))
(let world (block '(
(let result_sink (DataSink 'result))
(let world (Write! world result_sink (Key) output '('('type) '('autoref) '('columns '('"column0")))))
(let plato_sink (DataSink '"yt" '"plato"))
(let world (Commit! world plato_sink))
(return (Commit! world result_sink))
)))
(return world)
)))
(return world)
)
|
