blob: 0db96ff65490cdbdab5d0e99ed6442ae692d0889 (
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
|
(
(library "joins.yql")
(import join_module '"joins.yql")
(let config (DataSource 'config))
(let world (Configure! world config 'PureDataSource 'yt))
# Same as InputKV1
(let list1 (AsList
(AsStruct '('key (String '1)) '('v1 (String 'v11)))
(AsStruct '('key (String '2)) '('v1 (String 'v12)))
(AsStruct '('key (String '2)) '('v1 (String 'v12)))
(AsStruct '('key (String '2)) '('v1 (String 'v12)))
(AsStruct '('key (String '3)) '('v1 (String 'v13)))
(AsStruct '('key (String '3)) '('v1 (String 'v13)))
))
# Same as InputKV2
(let list2 (AsList
(AsStruct '('key (String '2)) '('v2 (String 'v22_extra_bytes)))
(AsStruct '('key (String '2)) '('v2 (String 'v22_extra_bytes)))
(AsStruct '('key (String '3)) '('v2 (String 'v23_extra_bytes)))
(AsStruct '('key (String '3)) '('v2 (String 'v23_extra_bytes)))
(AsStruct '('key (String '3)) '('v2 (String 'v23_extra_bytes)))
(AsStruct '('key (String '4)) '('v2 (String 'v24_extra_bytes)))
))
(let world (Apply (bind join_module 'doAllJoinsExceptCrossEx) world list1 list2 '('('right 'any))))
(return world)
)
|
