blob: 8684754149651c7a7264e81daa52a542b5ab6879 (
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
|
# do not check tmp here (YQL-130, YQL-131)
(
(let x (Read! world (DataSource 'yt 'plato) (Key '('table (String 'Input))) (Void) '()))
(let world (Left! x))
(let yt.plato.Input (Right! x))
(let select1_input3 yt.plato.Input)
(let output5 (block '(
(let select1_output select1_input3)
(let select1_output (Map select1_output (lambda '(row) (block '(
(let res (Struct))
(let res (AddMember res 'x (Int64 '1)))
(return res)
)
))))
(let select1_output (Sort select1_output (Bool 'false) (lambda '(row) (block '(
(let res (Member row 'x))
(return res)
)
))))
(let select1_output (Take select1_output (Uint64 '2)))
(return select1_output)
)
))
(let result_sink (DataSink 'result))
(let world (Write! world result_sink (Key) output5 '('('type) '('autoref))))
(let plato_sink (DataSink 'yt 'plato))
(let world (Commit! world plato_sink))
(let world (Commit! world result_sink))
(return world)
)
|
