| 164 | } |
| 165 | |
| 166 | private static final class icv implements Cmd { |
| 167 | public void execute(final HBaseClient client, String[] args) { |
| 168 | ensureArguments(args, 6, 7); |
| 169 | final AtomicIncrementRequest icv = |
| 170 | new AtomicIncrementRequest(args[2], args[3], args[4], args[5]); |
| 171 | if (args.length > 6) { |
| 172 | icv.setAmount(Long.parseLong(args[6])); |
| 173 | } |
| 174 | args = null; |
| 175 | try { |
| 176 | final long result = client.atomicIncrement(icv).joinUninterruptibly(); |
| 177 | LOG.info("ICV result=" + result); |
| 178 | } catch (Exception e) { |
| 179 | LOG.error("ICV failed", e); |
| 180 | } |
| 181 | } |
| 182 | } |
| 183 | |
| 184 | private static final class micv implements Cmd { |
| 185 | public void execute(final HBaseClient client, String[] args) { |
nothing calls this directly
no outgoing calls
no test coverage detected