summaryrefslogtreecommitdiffstats
path: root/yt/yql/tests/sql/suites/optimizers/fuse_map_mapreduce_multi_input.yql
blob: d1d973939b4bb66e95b24600902c70f1b1290a60 (plain) (blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
use plato;

pragma yt.MapJoinLimit="10G";
pragma yt.FuseMapToMapReduce="normal";

select t2.value
from Input
    cross join (VALUES (1, 1998), (2, 1998), (3, 1999)) as t1(key1, year)
    cross join (VALUES (4, "A"), (5, "B"), (6, "C")) as t2(key2, value)
where Input.key1 = t1.key1
    and t2.key2 = Input.key2
    and t1.year = 1998
group by t2.value;