305306307308309310311312313314315
scanners.add(scanner); ctx.addThread(scanner); } ctx.startThreads(); ctx.waitFor(millisToRun); ctx.stop(); LOG.info("Finished test. Writers:"); for (AtomicityWriter writer : writers) { LOG.info(" wrote " + writer.numWritten.get());
278279280281282283284285286287288
scanners.add(scanner); ctx.addThread(scanner); } ctx.startThreads(); ctx.waitFor(millisToRun); ctx.stop(); LOG.info("Loaders:"); LOG.info(" loaded " + loader.numBulkLoads.get()); LOG.info(" compations " + loader.numCompactions.get());
283284285286287288289290291292293
265266267268269270271272273274275
288289290291292293294295296297298
271272273274275276277278279280281
277278279280281282283284285286287
294295296297298299300301302303304
279280281282283284285286287288289