666768697071727374
} Thread.sleep(10000); client.close(); cluster.shutDown(); } }
7273747576777879808182
long end = System.nanoTime(); double ms = (end - start) / 1000000.0; client.close(); cluster.shutDown(); System.out.printf("Avg latency was %.3f ms.\n", ms / iterations); } catch (Exception e) {
201202203204205206207208209
client.close(); System.out.printf("Scanned at %f rows/sec after drain.\n", rows.get() / (nanos.get() / 1000000000.0)); cluster.shutDown(); } }