Skip to content

Commit 78ac89b

Browse files
committed
WIP
1 parent 1eb3094 commit 78ac89b

3 files changed

Lines changed: 46 additions & 5 deletions

File tree

performance-examples/duckdb-query/package_test.json

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -4,20 +4,20 @@
44
"script": {
55
"main": "perftest.sqrl",
66
"config": {
7-
"rowsPerSec": 200,
8-
"numRows": 800
7+
"rowsPerSec": 10,
8+
"numRows": 80000
99
}
1010
},
1111
"engines": {
1212
"flink": {
1313
"config": {
14-
"execution.checkpointing.interval": "10 sec"
14+
"execution.checkpointing.interval": "5 sec"
1515
}
1616
}
1717
},
1818
"connectors": {
1919
"iceberg": {
20-
"warehouse": "iceberg-data",
20+
"warehouse": "s3a://ferenc-iceberg-hadoop-test",
2121
"catalog-type": "hadoop",
2222
"catalog-name": "mydata"
2323
}
Lines changed: 41 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,41 @@
1+
{
2+
"version": "1",
3+
"enabled-engines": ["vertx", "iceberg", "duckdb", "flink"],
4+
"script": {
5+
"main": "perftest.sqrl",
6+
"config": {
7+
"rowsPerSec": 10,
8+
"numRows": 80000
9+
}
10+
},
11+
"engines": {
12+
"flink": {
13+
"config": {
14+
"execution.checkpointing.interval": "10 sec"
15+
}
16+
},
17+
"duckdb": {
18+
"url": "jdbc:duckdb:",
19+
"config": {
20+
"use-disk-cache": true,
21+
"use-aws": true,
22+
"aws-region": "eu-north-1"
23+
}
24+
}
25+
},
26+
"connectors": {
27+
"iceberg": {
28+
"connector": "iceberg",
29+
"warehouse": "s3://ferenc-iceberg-glue-test",
30+
"catalog-impl": "org.apache.iceberg.aws.glue.GlueCatalog",
31+
"io-impl": "org.apache.iceberg.aws.s3.S3FileIO",
32+
"catalog-name": "mycatalog",
33+
"catalog-database": "mydatabase",
34+
"write.upsert.enabled": "true"
35+
}
36+
},
37+
"test-runner": {
38+
"delay-sec": -1,
39+
"required-checkpoints": 2
40+
}
41+
}

performance-examples/duckdb-query/perftest.sqrl

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,4 +23,4 @@ MetricsByTime(machineid BIGINT NOT NULL, fromTime TIMESTAMP NOT NULL) :=
2323

2424
/*+test*/
2525
MetricsTest := SELECT AVG(metric) AS avg_metric, COUNT(metric) AS total_count
26-
FROM Metrics WHERE machineid = 5;
26+
FROM Metrics WHERE machineid = 5;

0 commit comments

Comments
 (0)