Skip to content

Commit 91ebcf5

Browse files
authored
Merge pull request ClickHouse#343 from chenkovsky/datafusion
[datafusion] Remove type conversions
2 parents b126e15 + 9702ff0 commit 91ebcf5

File tree

3 files changed

+94
-94
lines changed

3 files changed

+94
-94
lines changed

datafusion/queries.sql

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@ SELECT SUM("AdvEngineID"), COUNT(*), AVG("ResolutionWidth") FROM hits;
44
SELECT AVG("UserID") FROM hits;
55
SELECT COUNT(DISTINCT "UserID") FROM hits;
66
SELECT COUNT(DISTINCT "SearchPhrase") FROM hits;
7-
SELECT MIN("EventDate"::INT::DATE), MAX("EventDate"::INT::DATE) FROM hits;
7+
SELECT MIN("EventDate"), MAX("EventDate") FROM hits;
88
SELECT "AdvEngineID", COUNT(*) FROM hits WHERE "AdvEngineID" <> 0 GROUP BY "AdvEngineID" ORDER BY COUNT(*) DESC;
99
SELECT "RegionID", COUNT(DISTINCT "UserID") AS u FROM hits GROUP BY "RegionID" ORDER BY u DESC LIMIT 10;
1010
SELECT "RegionID", SUM("AdvEngineID"), COUNT(*) AS c, AVG("ResolutionWidth"), COUNT(DISTINCT "UserID") FROM hits GROUP BY "RegionID" ORDER BY c DESC LIMIT 10;
@@ -34,10 +34,10 @@ SELECT "WatchID", "ClientIP", COUNT(*) AS c, SUM("IsRefresh"), AVG("ResolutionWi
3434
SELECT "URL", COUNT(*) AS c FROM hits GROUP BY "URL" ORDER BY c DESC LIMIT 10;
3535
SELECT 1, "URL", COUNT(*) AS c FROM hits GROUP BY 1, "URL" ORDER BY c DESC LIMIT 10;
3636
SELECT "ClientIP", "ClientIP" - 1, "ClientIP" - 2, "ClientIP" - 3, COUNT(*) AS c FROM hits GROUP BY "ClientIP", "ClientIP" - 1, "ClientIP" - 2, "ClientIP" - 3 ORDER BY c DESC LIMIT 10;
37-
SELECT "URL", COUNT(*) AS PageViews FROM hits WHERE "CounterID" = 62 AND "EventDate"::INT::DATE >= '2013-07-01' AND "EventDate"::INT::DATE <= '2013-07-31' AND "DontCountHits" = 0 AND "IsRefresh" = 0 AND "URL" <> '' GROUP BY "URL" ORDER BY PageViews DESC LIMIT 10;
38-
SELECT "Title", COUNT(*) AS PageViews FROM hits WHERE "CounterID" = 62 AND "EventDate"::INT::DATE >= '2013-07-01' AND "EventDate"::INT::DATE <= '2013-07-31' AND "DontCountHits" = 0 AND "IsRefresh" = 0 AND "Title" <> '' GROUP BY "Title" ORDER BY PageViews DESC LIMIT 10;
39-
SELECT "URL", COUNT(*) AS PageViews FROM hits WHERE "CounterID" = 62 AND "EventDate"::INT::DATE >= '2013-07-01' AND "EventDate"::INT::DATE <= '2013-07-31' AND "IsRefresh" = 0 AND "IsLink" <> 0 AND "IsDownload" = 0 GROUP BY "URL" ORDER BY PageViews DESC LIMIT 10 OFFSET 1000;
40-
SELECT "TraficSourceID", "SearchEngineID", "AdvEngineID", CASE WHEN ("SearchEngineID" = 0 AND "AdvEngineID" = 0) THEN "Referer" ELSE '' END AS Src, "URL" AS Dst, COUNT(*) AS PageViews FROM hits WHERE "CounterID" = 62 AND "EventDate"::INT::DATE >= '2013-07-01' AND "EventDate"::INT::DATE <= '2013-07-31' AND "IsRefresh" = 0 GROUP BY "TraficSourceID", "SearchEngineID", "AdvEngineID", Src, Dst ORDER BY PageViews DESC LIMIT 10 OFFSET 1000;
41-
SELECT "URLHash", "EventDate"::INT::DATE, COUNT(*) AS PageViews FROM hits WHERE "CounterID" = 62 AND "EventDate"::INT::DATE >= '2013-07-01' AND "EventDate"::INT::DATE <= '2013-07-31' AND "IsRefresh" = 0 AND "TraficSourceID" IN (-1, 6) AND "RefererHash" = 3594120000172545465 GROUP BY "URLHash", "EventDate"::INT::DATE ORDER BY PageViews DESC LIMIT 10 OFFSET 100;
42-
SELECT "WindowClientWidth", "WindowClientHeight", COUNT(*) AS PageViews FROM hits WHERE "CounterID" = 62 AND "EventDate"::INT::DATE >= '2013-07-01' AND "EventDate"::INT::DATE <= '2013-07-31' AND "IsRefresh" = 0 AND "DontCountHits" = 0 AND "URLHash" = 2868770270353813622 GROUP BY "WindowClientWidth", "WindowClientHeight" ORDER BY PageViews DESC LIMIT 10 OFFSET 10000;
43-
SELECT DATE_TRUNC('minute', to_timestamp_seconds("EventTime")) AS M, COUNT(*) AS PageViews FROM hits WHERE "CounterID" = 62 AND "EventDate"::INT::DATE >= '2013-07-14' AND "EventDate"::INT::DATE <= '2013-07-15' AND "IsRefresh" = 0 AND "DontCountHits" = 0 GROUP BY DATE_TRUNC('minute', to_timestamp_seconds("EventTime")) ORDER BY DATE_TRUNC('minute', M) LIMIT 10 OFFSET 1000;
37+
SELECT "URL", COUNT(*) AS PageViews FROM hits WHERE "CounterID" = 62 AND "EventDate" >= '2013-07-01' AND "EventDate" <= '2013-07-31' AND "DontCountHits" = 0 AND "IsRefresh" = 0 AND "URL" <> '' GROUP BY "URL" ORDER BY PageViews DESC LIMIT 10;
38+
SELECT "Title", COUNT(*) AS PageViews FROM hits WHERE "CounterID" = 62 AND "EventDate" >= '2013-07-01' AND "EventDate" <= '2013-07-31' AND "DontCountHits" = 0 AND "IsRefresh" = 0 AND "Title" <> '' GROUP BY "Title" ORDER BY PageViews DESC LIMIT 10;
39+
SELECT "URL", COUNT(*) AS PageViews FROM hits WHERE "CounterID" = 62 AND "EventDate" >= '2013-07-01' AND "EventDate" <= '2013-07-31' AND "IsRefresh" = 0 AND "IsLink" <> 0 AND "IsDownload" = 0 GROUP BY "URL" ORDER BY PageViews DESC LIMIT 10 OFFSET 1000;
40+
SELECT "TraficSourceID", "SearchEngineID", "AdvEngineID", CASE WHEN ("SearchEngineID" = 0 AND "AdvEngineID" = 0) THEN "Referer" ELSE '' END AS Src, "URL" AS Dst, COUNT(*) AS PageViews FROM hits WHERE "CounterID" = 62 AND "EventDate" >= '2013-07-01' AND "EventDate" <= '2013-07-31' AND "IsRefresh" = 0 GROUP BY "TraficSourceID", "SearchEngineID", "AdvEngineID", Src, Dst ORDER BY PageViews DESC LIMIT 10 OFFSET 1000;
41+
SELECT "URLHash", "EventDate", COUNT(*) AS PageViews FROM hits WHERE "CounterID" = 62 AND "EventDate" >= '2013-07-01' AND "EventDate" <= '2013-07-31' AND "IsRefresh" = 0 AND "TraficSourceID" IN (-1, 6) AND "RefererHash" = 3594120000172545465 GROUP BY "URLHash", "EventDate" ORDER BY PageViews DESC LIMIT 10 OFFSET 100;
42+
SELECT "WindowClientWidth", "WindowClientHeight", COUNT(*) AS PageViews FROM hits WHERE "CounterID" = 62 AND "EventDate" >= '2013-07-01' AND "EventDate" <= '2013-07-31' AND "IsRefresh" = 0 AND "DontCountHits" = 0 AND "URLHash" = 2868770270353813622 GROUP BY "WindowClientWidth", "WindowClientHeight" ORDER BY PageViews DESC LIMIT 10 OFFSET 10000;
43+
SELECT DATE_TRUNC('minute', to_timestamp_seconds("EventTime")) AS M, COUNT(*) AS PageViews FROM hits WHERE "CounterID" = 62 AND "EventDate" >= '2013-07-14' AND "EventDate" <= '2013-07-15' AND "IsRefresh" = 0 AND "DontCountHits" = 0 GROUP BY DATE_TRUNC('minute', to_timestamp_seconds("EventTime")) ORDER BY DATE_TRUNC('minute', M) LIMIT 10 OFFSET 1000;

datafusion/results/partitioned.json

Lines changed: 43 additions & 43 deletions
Original file line numberDiff line numberDiff line change
@@ -8,48 +8,48 @@
88
"load_time": 0,
99
"data_size": 14779976446,
1010
"result": [
11-
[0.062, 0.019, 0.021],
12-
[0.117, 0.036, 0.035],
13-
[0.206, 0.084, 0.081],
14-
[0.385, 0.087, 0.086],
15-
[1.077, 0.873, 0.843],
16-
[1.014, 0.860, 0.858],
17-
[0.102, 0.036, 0.033],
18-
[0.125, 0.037, 0.038],
19-
[1.116, 0.943, 0.962],
20-
[1.343, 1.068, 1.041],
21-
[0.509, 0.258, 0.253],
22-
[0.639, 0.287, 0.302],
23-
[1.081, 0.891, 0.901],
24-
[2.708, 1.370, 1.418],
25-
[1.104, 0.854, 0.864],
26-
[1.108, 1.021, 1.016],
27-
[2.679, 1.820, 1.858],
28-
[2.511, 1.684, 1.696],
29-
[5.435, 3.718, 3.841],
30-
[0.260, 0.076, 0.081],
31-
[9.906, 1.077, 1.101],
32-
[11.275, 1.294, 1.288],
33-
[21.902, 2.510, 2.573],
34-
[55.539, 9.451, 9.515],
35-
[2.685, 0.453, 0.445],
36-
[0.798, 0.358, 0.358],
37-
[2.709, 0.514, 0.504],
38-
[9.663, 1.479, 1.502],
39-
[10.040, 9.552, 9.835],
40-
[0.524, 0.423, 0.413],
41-
[2.376, 0.796, 0.805],
42-
[5.963, 0.945, 0.911],
43-
[4.713, 3.666, 3.668],
44-
[10.233, 3.811, 3.796],
45-
[10.265, 3.756, 3.773],
46-
[1.378, 1.277, 1.249],
47-
[0.406, 0.203, 0.203],
48-
[0.209, 0.098, 0.082],
49-
[0.309, 0.117, 0.121],
50-
[0.642, 0.384, 0.369],
51-
[0.181, 0.052, 0.051],
52-
[0.167, 0.046, 0.045],
53-
[0.178, 0.055, 0.054]
11+
[0.060, 0.022, 0.021],
12+
[0.109, 0.034, 0.035],
13+
[0.198, 0.085, 0.083],
14+
[0.391, 0.088, 0.084],
15+
[1.143, 0.846, 0.872],
16+
[1.020, 0.856, 0.855],
17+
[0.086, 0.032, 0.028],
18+
[0.118, 0.037, 0.037],
19+
[1.102, 0.962, 0.942],
20+
[1.353, 1.070, 1.045],
21+
[0.487, 0.260, 0.263],
22+
[0.663, 0.291, 0.286],
23+
[1.114, 0.893, 0.901],
24+
[2.596, 1.410, 1.360],
25+
[1.133, 0.860, 0.854],
26+
[1.132, 1.020, 1.001],
27+
[2.668, 1.835, 1.866],
28+
[2.557, 1.694, 1.704],
29+
[5.337, 3.714, 3.794],
30+
[0.263, 0.082, 0.082],
31+
[9.891, 1.109, 1.125],
32+
[11.284, 1.331, 1.348],
33+
[21.820, 2.617, 2.631],
34+
[55.448, 9.609, 9.630],
35+
[2.687, 0.452, 0.453],
36+
[0.804, 0.368, 0.364],
37+
[2.704, 0.517, 0.520],
38+
[9.662, 1.553, 1.507],
39+
[9.988, 9.801, 9.769],
40+
[0.526, 0.421, 0.403],
41+
[2.371, 0.802, 0.812],
42+
[5.944, 0.904, 0.903],
43+
[4.827, 3.645, 3.565],
44+
[10.196, 3.767, 3.792],
45+
[10.234, 3.823, 3.844],
46+
[1.397, 1.270, 1.303],
47+
[0.328, 0.146, 0.147],
48+
[0.196, 0.085, 0.105],
49+
[0.328, 0.147, 0.150],
50+
[0.482, 0.220, 0.219],
51+
[0.198, 0.076, 0.076],
52+
[0.189, 0.088, 0.076],
53+
[0.179, 0.064, 0.075]
5454
]
5555
}

datafusion/results/single.json

Lines changed: 43 additions & 43 deletions
Original file line numberDiff line numberDiff line change
@@ -8,48 +8,48 @@
88
"load_time": 0,
99
"data_size": 14779976446,
1010
"result": [
11-
[0.106, 0.058, 0.070],
12-
[0.139, 0.077, 0.085],
13-
[0.217, 0.117, 0.127],
14-
[0.340, 0.121, 0.123],
15-
[1.029, 0.906, 0.900],
16-
[1.089, 0.950, 0.957],
17-
[0.123, 0.068, 0.077],
18-
[0.148, 0.085, 0.083],
19-
[1.134, 1.005, 0.977],
20-
[1.314, 1.095, 1.096],
21-
[0.484, 0.293, 0.290],
22-
[0.574, 0.313, 0.310],
23-
[1.141, 0.991, 0.971],
24-
[2.609, 1.554, 1.532],
25-
[1.086, 0.922, 0.941],
26-
[1.197, 1.056, 1.081],
27-
[2.676, 1.935, 1.930],
28-
[2.552, 1.805, 1.800],
29-
[5.212, 3.746, 3.798],
30-
[0.243, 0.117, 0.116],
31-
[9.731, 1.176, 1.139],
32-
[11.252, 1.439, 1.453],
33-
[22.124, 3.480, 3.546],
34-
[55.992, 9.964, 9.912],
35-
[2.588, 0.587, 0.563],
36-
[0.808, 0.507, 0.511],
37-
[2.584, 0.646, 0.640],
38-
[9.573, 1.607, 1.621],
39-
[10.865, 10.256, 10.331],
40-
[0.559, 0.454, 0.462],
41-
[2.281, 0.920, 0.936],
42-
[5.692, 1.004, 1.044],
43-
[4.539, 3.731, 3.757],
44-
[10.240, 3.861, 3.946],
45-
[10.201, 3.906, 3.870],
46-
[1.412, 1.288, 1.281],
47-
[0.421, 0.255, 0.243],
48-
[0.292, 0.154, 0.156],
49-
[0.360, 0.169, 0.189],
50-
[0.712, 0.413, 0.413],
51-
[0.211, 0.082, 0.087],
52-
[0.198, 0.091, 0.078],
53-
[0.199, 0.094, 0.089]
11+
[0.103, 0.063, 0.070],
12+
[0.136, 0.080, 0.079],
13+
[0.219, 0.117, 0.116],
14+
[0.348, 0.128, 0.128],
15+
[1.045, 0.913, 0.924],
16+
[1.102, 0.959, 0.964],
17+
[0.114, 0.066, 0.078],
18+
[0.152, 0.088, 0.087],
19+
[1.160, 1.021, 1.005],
20+
[1.324, 1.077, 1.110],
21+
[0.470, 0.297, 0.297],
22+
[0.567, 0.317, 0.312],
23+
[1.140, 0.984, 0.984],
24+
[2.681, 1.388, 1.459],
25+
[1.106, 0.952, 0.939],
26+
[1.185, 1.062, 1.067],
27+
[2.647, 1.943, 1.937],
28+
[2.524, 1.787, 1.787],
29+
[5.212, 3.749, 3.825],
30+
[0.272, 0.115, 0.122],
31+
[9.741, 1.205, 1.190],
32+
[11.298, 1.552, 1.497],
33+
[22.086, 3.670, 3.620],
34+
[55.936, 10.118, 10.120],
35+
[2.553, 0.572, 0.591],
36+
[0.792, 0.519, 0.512],
37+
[2.561, 0.639, 0.634],
38+
[9.600, 1.650, 1.682],
39+
[10.898, 10.343, 10.278],
40+
[0.556, 0.455, 0.459],
41+
[2.282, 0.938, 0.932],
42+
[5.685, 1.033, 1.025],
43+
[4.576, 3.773, 3.780],
44+
[10.309, 3.906, 3.927],
45+
[10.317, 3.969, 4.025],
46+
[1.395, 1.251, 1.253],
47+
[0.364, 0.202, 0.199],
48+
[0.284, 0.163, 0.164],
49+
[0.385, 0.216, 0.198],
50+
[0.541, 0.302, 0.295],
51+
[0.224, 0.115, 0.111],
52+
[0.215, 0.108, 0.111],
53+
[0.193, 0.102, 0.100]
5454
]
5555
}

0 commit comments

Comments
 (0)