| 263 | } |
| 264 | |
| 265 | @TestOnly |
| 266 | public void clear() { |
| 267 | columnPurgeSubSeq.clear(); |
| 268 | postingSealPurgeSubSeq.clear(); |
| 269 | groupByLongTopKSubSeq.clear(); |
| 270 | groupByMergeShardSubSeq.clear(); |
| 271 | indexerSubSeq.clear(); |
| 272 | latestBySubSeq.clear(); |
| 273 | columnTaskSubSeq.clear(); |
| 274 | o3CopySubSeq.clear(); |
| 275 | o3OpenColumnSubSeq.clear(); |
| 276 | o3PartitionSubSeq.clear(); |
| 277 | o3PurgeDiscoverySubSeq.clear(); |
| 278 | copyImportColSeq.clear(); |
| 279 | copyImportRequestSubSeq.clear(); |
| 280 | copyImportSubSeq.clear(); |
| 281 | copyExportRequestSubSeq.clear(); |
| 282 | vectorAggregateSubSeq.clear(); |
| 283 | walTxnNotificationSubSequence.clear(); |
| 284 | queryCacheEventSubSeq.clear(); |
| 285 | unorderedPageFrameReduceSubSeq.clear(); |
| 286 | for (int i = 0, n = pageFrameReduceSubSeq.length; i < n; i++) { |
| 287 | pageFrameReduceSubSeq[i].clear(); |
| 288 | } |
| 289 | // Reset tasks with native backing memory to the original state. |
| 290 | for (int i = 0; i < pageFrameReduceShardCount; i++) { |
| 291 | for (int j = 0, n = pageFrameReduceQueue[i].getCycle(); j < n; j++) { |
| 292 | pageFrameReduceQueue[i].get(j).clear(); |
| 293 | } |
| 294 | } |
| 295 | for (int i = 0, n = latestByQueue.getCycle(); i < n; i++) { |
| 296 | latestByQueue.get(i).clear(); |
| 297 | } |
| 298 | } |
| 299 | |
| 300 | @Override |
| 301 | public void close() { |