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.");
      }
    }
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



grpc-gcp-benchmarks/src/main/SpannerClientTestCases.java [141:158]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  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.");
      }
    }
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



grpc-gcp-benchmarks/src/benchmarkTest/java/SpannerClientTestCases.java [164:181]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  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.");
      }
    }
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



