Class micv

test/Test.java:184–206

  }

  private static final class micv implements Cmd {
    public void execute(final HBaseClient client, String[] args) {
      ensureArguments(args, 6, 7);
      final MultiColumnAtomicIncrementRequest micv =
        new MultiColumnAtomicIncrementRequest(args[2], args[3], args[4], args[5].split(","));
      if (args.length > 6) {
        String[] raw = args[6].split(",");
        long[] amounts = new long[raw.length];
        for(int i = 0; i < amounts.length; i++) {
          amounts[i] = Long.parseLong(raw[i]);
        }
        micv.setAmounts(amounts);
      }
      args = null;
      try {
        final Map<byte[], Long> result = client.atomicIncrement(micv).joinUninterruptibly();
        final String formatted = Joiner.on("->").withKeyValueSeparator(";").join(result);
        LOG.info("MICV result=" + formatted);
      } catch (Exception e) {
        LOG.error("ICV failed", e);
      }
    }
  }

  private static final class put implements Cmd {
    public void execute(final HBaseClient client, String[] args) throws Exception {