blob: 25d3e102c61e65136f5bbd01fda5bc1ee08c7543 (
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
70
71
72
|
(
(let config (DataSource 'config))
(let world (Configure! world config 'PureDataSource 'yt))
(import aggregate_module '"/lib/yql/aggregate.yql")
(import window_module '"/lib/yql/window.yql")
(import core_module '"/lib/yql/core.yql")
(let world (block '(
(let output (block '(
(let select (block '(
(let core (AsList (Uint32 '0)))
(let core (FlatMap core (lambda '(row) (block '(
(let res (AsStruct '('"column0" ("Apply" ("bind" core_module '"Decode") (String '"key1") ("AsList" (String '"key1") (String '"value1") (String '"key2") (String '"value2")) (String '"default")))))
(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")))))
(return (Commit! world result_sink))
)))
(return world)
)))
(let world (block '(
(let output (block '(
(let select (block '(
(let core (AsList (Uint32 '0)))
(let core (FlatMap core (lambda '(row) (block '(
(let res (AsStruct '('"column0" ("Apply" ("bind" core_module '"Decode") (String '"key2") ("AsList" (String '"key1") (String '"value1") (String '"key2") (String '"value2")) (String '"default")))))
(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")))))
(return (Commit! world result_sink))
)))
(return world)
)))
(let world (block '(
(let output (block '(
(let select (block '(
(let core (AsList (Uint32 '0)))
(let core (FlatMap core (lambda '(row) (block '(
(let res (AsStruct '('"column0" ("Apply" ("bind" core_module '"Decode") (String '"keyZ") ("AsList" (String '"key1") (String '"value1") (String '"key2") (String '"value2")) (String '"default")))))
(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")))))
(return (Commit! world result_sink))
)))
(return world)
)))
(let world (block '(
(return world)
)))
(return world)
)
|
