in grpc-gcp-benchmarks/src/main/java/com/google/grpc/gcp/SpannerClientTestCases.java [144:161]
public void readOneThread(DatabaseClient db, int thread, List<Long> result) {
for (int i = 0; i < numOfRpcs; i++) {
int lineCount = 0;
long start = System.currentTimeMillis();
try (ResultSet resultSet =
db.singleUse().read(LARGE_TABLE, KeySet.all(), Arrays.asList("id", "data", "rpc"))) {
while (resultSet.next()) {
lineCount++;
}
}
if (result != null) {
result.add(System.currentTimeMillis() - start);
}
if (lineCount != numOfRpcs * numOfThreads) {
System.out.println("WARNING: Imcomplete data.");
}
}
}