Skip to content

Commit a852daa

Browse files
committed
benchmark: Drop side_input table from most Nexmark queries.
Only query q13 uses the `side_input` table but all of them had it defined. This moves it to just query q13, because having it in the others kept them from working with fault tolerance (because `side_input` uses the datagen connect that doesn't implement FT yet). Signed-off-by: Ben Pfaff <blp@feldera.com>
1 parent 352bf3e commit a852daa

File tree

2 files changed

+21
-20
lines changed

2 files changed

+21
-20
lines changed

benchmark/feldera-sql/benchmarks/nexmark/queries/q13.sql

Lines changed: 21 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,24 @@
1+
CREATE TABLE side_input (
2+
date_time TIMESTAMP,
3+
key BIGINT,
4+
value VARCHAR
5+
) WITH ('connectors' = '[{
6+
"transport": {
7+
"name": "datagen",
8+
"config": {
9+
"plan": [
10+
{
11+
"limit": 100,
12+
"fields": {
13+
"date_time": { "range": [1724444408000, 4102444800000] },
14+
"key": { "range": [0, 100] }
15+
}
16+
}
17+
]
18+
}
19+
}
20+
}]');
21+
122
CREATE VIEW Q13 AS
223
SELECT
324
B.auction,

benchmark/feldera-sql/benchmarks/nexmark/table.sql

Lines changed: 0 additions & 20 deletions
Original file line numberDiff line numberDiff line change
@@ -74,23 +74,3 @@ CREATE TABLE bid (
7474
"max_batch_size": 160000
7575
}}
7676
]');
77-
CREATE TABLE side_input (
78-
date_time TIMESTAMP,
79-
key BIGINT,
80-
value VARCHAR
81-
) WITH ('connectors' = '[{{
82-
"transport": {{
83-
"name": "datagen",
84-
"config": {{
85-
"plan": [
86-
{{
87-
"limit": 100,
88-
"fields": {{
89-
"date_time": {{ "range": [1724444408000, 4102444800000] }},
90-
"key": {{ "range": [0, 100] }}
91-
}}
92-
}}
93-
]
94-
}}
95-
}}
96-
}}]');

0 commit comments

Comments
 (0)