blob: 0a2a83b345ac6110375ba96cb842b6fe062978a5 (
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
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
|
(
(let world (block '(
(let x (Read! world (DataSource '"yt" '"plato") (Key '('table (String '"Input"))) '('"key" '"value") '()))
(let world (Left! x))
(let table0 (Right! x))
(let output (block '(
(let select (block '(
(let core (block '(
(let select (block '(
(let core table0)
(let core (FlatMap core (lambda '(row) (block '(
(let res (Struct))
(let res (AddMember res '"key" (Member row '"key")))
(let res (AddMember res '"value1" (MatchType (Member row '"value") 'Optional (lambda '(item) (Coalesce (Map item (lambda '(val) (IfType val (DataType 'String) (lambda '(item) (FromString item '"Int64")) (lambda '(item) (Just (Convert item '"Int64")))))) (Nothing (OptionalType (DataType '"Int64"))))) (lambda '(item) (IfType item (DataType 'String) (lambda '(item) (FromString item '"Int64")) (lambda '(item) (Convert item '"Int64")))))))
(let res (AsList res))
(return res)
)
))))
(return core)
)
))
(return select)
)
))
(let core (block '(
(let Max1_create (lambda '(row) (Member row '"value1")))
(let Max1_update (lambda '(row state) (OptionalReduce state (Member row '"value1") (lambda '(a b) (Max a b)))))
(let Max1_save (lambda '(state) state))
(let Max1_load (lambda '(item) item))
(let Max1_merge (lambda '(a b) (OptionalReduce a b (lambda '(a b) (Max a b)))))
(let Max1_finish (lambda '(state) state))
(let Count2_create (lambda '(row) (Convert (Exists row) 'Uint64)))
(let Count2_update (lambda '(row state) (OptionalReduce state (Convert (Exists row) 'Uint64) (lambda '(a b) (+ a b)))))
(let Count2_save (lambda '(state) state))
(let Count2_load (lambda '(item) item))
(let Count2_merge (lambda '(a b) (OptionalReduce a b (lambda '(a b) (+ a b)))))
(let Count2_finish (lambda '(state) state))
(return (Aggregate core '('"key") '('('Max1 (AggregationTraits (ListItemType (TypeOf core)) Max1_create Max1_update Max1_save Max1_load Max1_merge Max1_finish (Null))) '('Count2 (AggregationTraits (StructMemberType (ListItemType (TypeOf core)) '"value1") Count2_create Count2_update Count2_save Count2_load Count2_merge Count2_finish (Uint64 '0)) '"value1"))))
)
))
(let core (FlatMap core (lambda '(row) (block '(
(let res (Struct))
(let res (AddMember res '"column0" (Member row 'Max1)))
(let res (AddMember res '"key" (Member row '"key")))
(let res (AddMember res '"column2" (Member row 'Count2)))
(let res (AsList res))
(return res)
)
))))
(return core)
)
))
(return select)
)
))
(let world (block '(
(let result_sink (DataSink 'result))
(let sortedOutput (Sort output (Bool 'false) (lambda '(x) (Member x 'key) )))
(let world (Write! world result_sink (Key) sortedOutput '('('type) '('autoref) '('columns '('"column0" '"key" '"column2")))))
(let plato_sink (DataSink '"yt" '"plato"))
(let world (Commit! world plato_sink))
(return (Commit! world result_sink))
)
))
(return world)
)
))
(return world)
)
|
