Method execute

test/Test.java:297–335

(final HBaseClient client, String[] args)

  private static final class mscan implements Cmd {
    @SuppressWarnings("fallthrough")
    public void execute(final HBaseClient client, String[] args) {
      ensureArguments(args, 3, 7);
      final Scanner scanner = client.newScanner(args[2]);
      switch (args.length) {
        case 7: scanner.setKeyRegexp(args[6]);
        case 6: scanner.setStopKey(args[5]);
        case 5:
          final String columns = args[4];
          final ArrayList<byte[]> families = new ArrayList<byte[]>();
          final ArrayList<byte[][]> qualifiers = new ArrayList<byte[][]>();
          for (String spec : columns.split("/")) {
            final String[] family = spec.split(":");
            families.add(family[0].getBytes());
            if (family.length == 1) {
              qualifiers.add(null);
            } else {
              final String[] quals = family[1].split(",");
              final byte[][] qb = new byte[quals.length][];
              for (int i = 0; i < qb.length; i++) {
                qb[i] = quals[i].getBytes();
              }
              qualifiers.add(qb);
            }
          }
          scanner.setFamilies(families.toArray(new byte[families.size()][]),
                              qualifiers.toArray(new byte[qualifiers.size()][][]));
        case 4: scanner.setStartKey(args[3]);
      }
      LOG.info("Start scanner=" + scanner);
      try {
        ArrayList<ArrayList<KeyValue>> rows;
        while ((rows = scanner.nextRows().joinUninterruptibly()) != null) {
          LOG.info("scanned results=" + rows + " from " + scanner);
        }
      } catch (Exception e) {
        LOG.error("Scan failed", e);
      }
    }
  }

  private static final class cas implements Cmd {