summaryrefslogtreecommitdiffstats
path: root/yql/essentials/tests/sql/suites/join/yql-20085-distinct.yql
blob: 0ca355a0148bc4269f9a7cf2ced5397ae76d02f5 (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
PRAGMA FilterPushdownOverJoinOptionalSide;

$t1 = (
    SELECT DISTINCT
        k1
    FROM
        AS_TABLE(AsList(
            AsStruct(0 AS k1),
            AsStruct(1 AS k1),
            AsStruct(2 AS k1),
            AsStruct(3 AS k1),
            AsStruct(4 AS k1),
            AsStruct(5 AS k1),
        ))
);

$t2 = (
    SELECT
        k2,
        SUM(v2) AS v2
    FROM
        AS_TABLE(AsList(
            AsStruct(2 AS k2, 1 AS v2),
            AsStruct(3 AS k2, 1 AS v2),
            AsStruct(4 AS k2, 1 AS v2),
            AsStruct(5 AS k2, 1 AS v2),
            AsStruct(6 AS k2, 1 AS v2),
            AsStruct(7 AS k2, 1 AS v2),
        ))
    GROUP BY
        k2
);

$t3 = (
    SELECT
        k3,
        SUM(v3) AS v3
    FROM
        AS_TABLE(AsList(
            AsStruct(4 AS k3, 1 AS v3),
            AsStruct(5 AS k3, 1 AS v3),
            AsStruct(6 AS k3, 1 AS v3),
            AsStruct(7 AS k3, 1 AS v3),
            AsStruct(8 AS k3, 1 AS v3),
            AsStruct(9 AS k3, 1 AS v3),
        ))
    GROUP BY
        k3
);

SELECT
    *
FROM
    $t1 AS t1
LEFT JOIN
    $t2 AS t2
ON
    t1.k1 == t2.k2
LEFT JOIN
    $t3 AS t3
ON
    t1.k1 == t3.k3
WHERE
    t2.v2 < 10
    AND t3.v3 < 10
;