Skip to content

Commit a91cf35

Browse files
feat(kqp): enable stream join for data query (#9568)
1 parent e95ff27 commit a91cf35

File tree

65 files changed

+1947
-4091
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

65 files changed

+1947
-4091
lines changed

ydb/core/kqp/ut/view/input/cases/aggregates_and_window/etalon_query.sql

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -43,4 +43,4 @@ FROM (
4343
JOIN `/Root/series`
4444
AS series
4545
USING (series_id)
46-
);
46+
) ORDER BY series;
Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,4 @@
11
SELECT
22
*
3-
FROM `/Root/aggregates_and_window`;
3+
FROM `/Root/aggregates_and_window`
4+
ORDER BY series;

ydb/core/kqp/ut/view/input/cases/count_episodes/etalon_query.sql

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -9,4 +9,4 @@ FROM (
99
GROUP BY
1010
series_id,
1111
season_id
12-
);
12+
) ORDER BY series_id, season_id;
Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,4 @@
11
SELECT
22
*
3-
FROM `/Root/count_episodes`;
3+
FROM `/Root/count_episodes`
4+
ORDER BY series_id, season_id;

ydb/core/kqp/ut/view/input/cases/count_episodes_with_titles/etalon_query.sql

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,4 +22,4 @@ FROM (
2222
JOIN `/Root/seasons`
2323
AS seasons
2424
ON episodes.series_id == seasons.series_id AND episodes.season_id == seasons.season_id
25-
);
25+
) ORDER BY series, season;
Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,4 @@
11
SELECT
22
*
3-
FROM `/Root/count_episodes_with_titles`;
3+
FROM `/Root/count_episodes_with_titles`
4+
ORDER BY series, season;

ydb/core/kqp/ut/view/input/cases/multiple_tables/etalon_query.sql

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -18,4 +18,4 @@ FROM (
1818
)
1919
AS seasons_and_episodes
2020
ON series.series_id == seasons_and_episodes.series_id
21-
);
21+
) ORDER BY series_id;
Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,4 @@
11
SELECT
22
*
3-
FROM `/Root/read_from_multiple_tables`;
3+
FROM `/Root/read_from_multiple_tables`
4+
ORDER BY series_id;

ydb/core/kqp/ut/view/input/cases/multiple_views/etalon_query.sql

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -9,4 +9,4 @@ FROM (
99
JOIN `/Root/view_seasons`
1010
AS seasons
1111
ON series.series_id == seasons.series_id
12-
);
12+
) ORDER BY series_title, seasons_title;
Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,4 @@
11
SELECT
22
*
3-
FROM `/Root/read_from_multiple_views`;
3+
FROM `/Root/read_from_multiple_views`
4+
ORDER BY series_title, seasons_title;

0 commit comments

Comments
 (0)