3 files changed
+33
-25
lines changed- .github/readme-benchmark.png
- benchmarks/pom.xml+1-1
- ci/templates/hosted-jobs.yml+64-7
- ci/templates/self-hosted-jobs.yml+6-8
- ci/templates/start-self-hosted-job.yml-48
- ci/templates/steps.yml+20-4
- compat/pom.xml+1-1
- core/pom.xml+1-1
- core/src/main/java/io/questdb/cairo/ListColumnFilter.java+1-1
- core/src/main/java/io/questdb/cairo/pool/AbstractMultiTenantPool.java+3-1
- core/src/main/java/io/questdb/cutlass/line/tcp/TableUpdateDetails.java+1-3
- core/src/main/java/io/questdb/griffin/SqlCodeGenerator.java+111-114
- core/src/main/java/io/questdb/griffin/SqlHints.java+9-9
- core/src/main/java/io/questdb/griffin/engine/QueryProgress.java+1
- core/src/main/java/io/questdb/griffin/engine/functions/date/GenerateSeriesTimestampStringRecordCursorFactory.java+35-62
- core/src/main/java/io/questdb/griffin/engine/join/AsOfJoinSingleSymbolRecordCursorFactory.java+302
- core/src/main/java/io/questdb/griffin/engine/join/AsofJoinColumnAccessHelper.java+6
- core/src/main/java/io/questdb/griffin/engine/join/NoopColumnAccessHelper.java-1
- core/src/main/java/io/questdb/griffin/engine/join/SingleSymbolColumnAccessHelper.java+8
- core/src/main/java/io/questdb/griffin/engine/table/AsyncFilteredRecordCursor.java+2-3
- core/src/main/java/io/questdb/std/Hash.java+1-1
- core/src/test/java/io/questdb/test/AbstractCairoTest.java+1-1
- core/src/test/java/io/questdb/test/ServerMainForeignTableTest.java+14-12
- core/src/test/java/io/questdb/test/cairo/fuzz/CheckpointFuzzTest.java+2-14
- core/src/test/java/io/questdb/test/cairo/fuzz/DedupInsertFuzzTest.java+2-16
- core/src/test/java/io/questdb/test/cairo/fuzz/O3MaxLagFuzzTest.java-18
- core/src/test/java/io/questdb/test/cairo/fuzz/O3ParquetPartitionFuzzTest.java-17
- core/src/test/java/io/questdb/test/cairo/fuzz/ParallelGroupByFuzzTest.java+1.6k-1.3k
- core/src/test/java/io/questdb/test/cairo/mv/MatViewTest.java+1.4k-907
- core/src/test/java/io/questdb/test/cairo/o3/AbstractO3Test.java+4-33
- core/src/test/java/io/questdb/test/cairo/o3/O3FailureFuzzTest.java+3-20
- core/src/test/java/io/questdb/test/cairo/o3/O3FailureTest.java+566-555
- core/src/test/java/io/questdb/test/cairo/o3/O3MaxLagTest.java+15-27
- core/src/test/java/io/questdb/test/cairo/o3/O3MetricsTest.java+18-32
- core/src/test/java/io/questdb/test/cairo/o3/O3SplitPartitionTest.java+77-91
- core/src/test/java/io/questdb/test/cairo/o3/O3SquashPartitionTest.java+158-116
- core/src/test/java/io/questdb/test/cairo/o3/O3Test.java+814-806
- core/src/test/java/io/questdb/test/cutlass/http/line/LineHttpSenderLoggingTest.java+2-8
- core/src/test/java/io/questdb/test/cutlass/line/tcp/AbstractLineTcpReceiverFuzzTest.java+2-14
- core/src/test/java/io/questdb/test/cutlass/line/tcp/AlterTableLineTcpReceiverTest.java+2-15
- core/src/test/java/io/questdb/test/cutlass/line/tcp/AlterWalTableLineTcpReceiverTest.java+2-15
- core/src/test/java/io/questdb/test/cutlass/line/tcp/BaseLineTcpInsertGeoHashTest.java+2-15
- core/src/test/java/io/questdb/test/cutlass/line/tcp/LineTcpCommitFuzzTest.java-4
- core/src/test/java/io/questdb/test/cutlass/line/tcp/LineTcpConnectionContextTest.java+4-16
- core/src/test/java/io/questdb/test/cutlass/line/tcp/LineTcpInsertByteGeoHashTest.java+80-53
- core/src/test/java/io/questdb/test/cutlass/line/tcp/LineTcpInsertIntGeoHashTest.java+103-83
- core/src/test/java/io/questdb/test/cutlass/line/tcp/LineTcpInsertLongGeoHashTest.java+97-76
- core/src/test/java/io/questdb/test/cutlass/line/tcp/LineTcpInsertShortGeoHashTest.java+107-86
- core/src/test/java/io/questdb/test/cutlass/line/tcp/LineTcpO3Test.java+2-14
- core/src/test/java/io/questdb/test/cutlass/line/tcp/LineTcpReceiverDropTableFuzzTest.java-4
- core/src/test/java/io/questdb/test/cutlass/line/tcp/LineTcpReceiverFuzzTest.java-4
- core/src/test/java/io/questdb/test/cutlass/line/tcp/LineTcpReceiverTest.java+250-176
- core/src/test/java/io/questdb/test/cutlass/line/tcp/LineTcpReceiverUpdateFuzzTest.java-4
- core/src/test/java/io/questdb/test/cutlass/line/tcp/LineTcpSenderTest.java+4-16
- core/src/test/java/io/questdb/test/cutlass/pgwire/PGArraysTest.java+138-88
- core/src/test/java/io/questdb/test/cutlass/pgwire/PGJobContextTest.java+3.7k-3.3k
- core/src/test/java/io/questdb/test/cutlass/pgwire/PreparedStatementInvalidationTest.java+99-79
- core/src/test/java/io/questdb/test/cutlass/text/TextLoaderTest.java+1.8k-1.6k
- core/src/test/java/io/questdb/test/griffin/AggregateTest.java+390-307
- core/src/test/java/io/questdb/test/griffin/AlterTableChangeColumnTypeTest.java+97-118
- core/src/test/java/io/questdb/test/griffin/AlterTableConvertPartitionTest.java+38-44
- core/src/test/java/io/questdb/test/griffin/CheckpointTest.java+2-15
- core/src/test/java/io/questdb/test/griffin/CopyImportTest.java+8-21
- core/src/test/java/io/questdb/test/griffin/InsertTest.java+421-131
- core/src/test/java/io/questdb/test/griffin/ParallelFilterTest.java+158-151
- core/src/test/java/io/questdb/test/griffin/ParallelLatestByTest.java+4-19
- core/src/test/java/io/questdb/test/griffin/SqlHintsTest.java+16-16
- core/src/test/java/io/questdb/test/griffin/SqlOptimiserTest.java+5-10
- core/src/test/java/io/questdb/test/griffin/TableBackupTest.java+22-26
- core/src/test/java/io/questdb/test/griffin/UpdateTest.java+1.1k-834
- core/src/test/java/io/questdb/test/griffin/engine/SqlCodeGeneratorTest.java+1-1
- core/src/test/java/io/questdb/test/griffin/engine/SqlCompilerImplTest.java+1-1
- core/src/test/java/io/questdb/test/griffin/engine/functions/bool/InLongFunctionFactoryTest.java+69-51
- core/src/test/java/io/questdb/test/griffin/engine/functions/geohash/GeoHashQueryTest.java+17-2
- core/src/test/java/io/questdb/test/griffin/engine/join/AsOfJoinFuzzTest.java+15-26
- core/src/test/java/io/questdb/test/griffin/engine/join/AsOfJoinNoKeyTest.java+11-32
- core/src/test/java/io/questdb/test/griffin/engine/join/AsOfJoinTest.java+367-199
- core/src/test/java/io/questdb/test/griffin/engine/join/JoinTest.java+1-1
- core/src/test/java/io/questdb/test/griffin/engine/table/parquet/PartitionEncoderTest.java+3-16
- core/src/test/java/io/questdb/test/griffin/engine/window/WindowFunctionTest.java+2.3k-1.9k
- core/src/test/java/io/questdb/test/log/SqlLoggingTest.java+4-1
- core/src/test/java/io/questdb/test/tools/TestUtils.java+44
- examples/pom.xml+1-1
- pom.xml+1-1
- utils/pom.xml+1-1
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
67 | 67 | | |
68 | 68 | | |
69 | 69 | | |
70 | | - | |
71 | | - | |
72 | | - | |
73 | 70 | | |
74 | 71 | | |
75 | 72 | | |
76 | 73 | | |
77 | 74 | | |
78 | 75 | | |
79 | 76 | | |
80 | | - | |
| 77 | + | |
| 78 | + | |
| 79 | + | |
81 | 80 | | |
82 | 81 | | |
83 | 82 | | |
| |||
88 | 87 | | |
89 | 88 | | |
90 | 89 | | |
91 | | - | |
92 | | - | |
93 | | - | |
94 | 90 | | |
95 | 91 | | |
96 | 92 | | |
97 | 93 | | |
98 | 94 | | |
99 | 95 | | |
| 96 | + | |
| 97 | + | |
| 98 | + | |
100 | 99 | | |
101 | 100 | | |
102 | 101 | | |
| |||
106 | 105 | | |
107 | 106 | | |
108 | 107 | | |
109 | | - | |
110 | | - | |
111 | | - | |
112 | 108 | | |
113 | 109 | | |
114 | 110 | | |
115 | 111 | | |
116 | 112 | | |
117 | 113 | | |
118 | 114 | | |
| 115 | + | |
| 116 | + | |
| 117 | + | |
119 | 118 | | |
120 | 119 | | |
121 | 120 | | |
| |||
137 | 136 | | |
138 | 137 | | |
139 | 138 | | |
140 | | - | |
141 | | - | |
142 | | - | |
143 | 139 | | |
144 | 140 | | |
145 | 141 | | |
146 | 142 | | |
147 | 143 | | |
148 | 144 | | |
149 | 145 | | |
| 146 | + | |
| 147 | + | |
| 148 | + | |
150 | 149 | | |
151 | 150 | | |
152 | 151 | | |
| |||
168 | 167 | | |
169 | 168 | | |
170 | 169 | | |
171 | | - | |
172 | | - | |
173 | | - | |
174 | 170 | | |
175 | 171 | | |
176 | 172 | | |
177 | 173 | | |
178 | 174 | | |
179 | 175 | | |
180 | 176 | | |
| 177 | + | |
| 178 | + | |
| 179 | + | |
181 | 180 | | |
182 | 181 | | |
183 | 182 | | |
| |||
225 | 224 | | |
226 | 225 | | |
227 | 226 | | |
228 | | - | |
229 | | - | |
230 | | - | |
231 | 227 | | |
232 | 228 | | |
233 | 229 | | |
234 | 230 | | |
235 | 231 | | |
236 | 232 | | |
237 | 233 | | |
| 234 | + | |
| 235 | + | |
| 236 | + | |
238 | 237 | | |
239 | 238 | | |
240 | 239 | | |
| |||
251 | 250 | | |
252 | 251 | | |
253 | 252 | | |
254 | | - | |
255 | | - | |
256 | | - | |
257 | 253 | | |
258 | 254 | | |
259 | 255 | | |
260 | 256 | | |
261 | 257 | | |
262 | 258 | | |
263 | 259 | | |
| 260 | + | |
| 261 | + | |
| 262 | + | |
264 | 263 | | |
265 | 264 | | |
266 | 265 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
46 | 46 | | |
47 | 47 | | |
48 | 48 | | |
| 49 | + | |
| 50 | + | |
| 51 | + | |
| 52 | + | |
| 53 | + | |
| 54 | + | |
| 55 | + | |
| 56 | + | |
| 57 | + | |
49 | 58 | | |
50 | 59 | | |
51 | 60 | | |
| |||
130 | 139 | | |
131 | 140 | | |
132 | 141 | | |
133 | | - | |
| 142 | + | |
134 | 143 | | |
135 | 144 | | |
136 | 145 | | |
137 | 146 | | |
138 | 147 | | |
139 | | - | |
| 148 | + | |
140 | 149 | | |
141 | 150 | | |
142 | 151 | | |
| |||
0 commit comments