MCPcopy Create free account
hub / github.com/OpenTSDB/asynchbase / execute

Method execute

test/Test.java:272–293  ·  view source on GitHub ↗
(final HBaseClient client, String[] args)

Source from the content-addressed store, hash-verified

270
271 private static final class scan implements Cmd {
272 @SuppressWarnings("fallthrough")
273 public void execute(final HBaseClient client, String[] args) {
274 ensureArguments(args, 3, 8);
275 final Scanner scanner = client.newScanner(args[2]);
276 switch (args.length) {
277 case 8: scanner.setKeyRegexp(args[7]);
278 case 7: scanner.setStopKey(args[6]);
279 case 6: scanner.setQualifier(args[5]);
280 case 5: scanner.setFamily(args[4]);
281 case 4: scanner.setStartKey(args[3]);
282 }
283 args = null;
284 LOG.info("Start scanner=" + scanner);
285 try {
286 ArrayList<ArrayList<KeyValue>> rows;
287 while ((rows = scanner.nextRows().joinUninterruptibly()) != null) {
288 LOG.info("scanned results=" + rows + " from " + scanner);
289 }
290 } catch (Exception e) {
291 LOG.error("Scan failed", e);
292 }
293 }
294 }
295
296 private static final class mscan implements Cmd {

Callers

nothing calls this directly

Calls 8

setKeyRegexpMethod · 0.95
setStopKeyMethod · 0.95
setQualifierMethod · 0.95
setFamilyMethod · 0.95
setStartKeyMethod · 0.95
nextRowsMethod · 0.95
ensureArgumentsMethod · 0.80
newScannerMethod · 0.80

Tested by

no test coverage detected