Method run

hbase098/src/main/java/site/ycsb/db/HBaseClient.java:421–460

()

    for (int i = 0; i < threadcount; i++) {
      Thread t = new Thread() {
        public void run() {
          try {
            Random random = new Random();

            HBaseClient cli = new HBaseClient();

            Properties props = new Properties();
            props.setProperty("columnfamily", columnfamily);
            props.setProperty("debug", "true");
            cli.setProperties(props);

            cli.init();

            long accum = 0;

            for (int i = 0; i < opcount; i++) {
              int keynum = random.nextInt(keyspace);
              String key = "user" + keynum;
              long st = System.currentTimeMillis();
              Status result;
              Vector<HashMap<String, ByteIterator>> scanResults = new Vector<>();
              Set<String> scanFields = new HashSet<String>();
              result = cli.scan("table1", "user2", 20, null, scanResults);

              long en = System.currentTimeMillis();

              accum += (en - st);

              if (!result.equals(Status.OK)) {
                System.out.println("Error " + result + " for " + key);
              }

              if (i % 10 == 0) {
                System.out.println(i + " operations, average latency: " + (((double) accum) / ((double) i)));
              }
            }
          } catch (Exception e) {
            e.printStackTrace();
          }
        }
      };
      allthreads.add(t);
    }