public void run()

in modules/accumulo/src/main/java/org/apache/fluo/recipes/accumulo/cmds/CompactTransient.java [61:82]

• 17 lines of code
• 3 McCabe index (conditional complexity)

    public void run() {

      long t1 = System.currentTimeMillis();

      try {
        TableOperations.compactTransient(fluoConfig, transientRange);
      } catch (Exception e) {
        log.warn("Compaction of " + transientRange + " failed ", e);
      }

      long t2 = System.currentTimeMillis();

      long sleepTime = Math.max((long) (multiplier * (t2 - t1)), requestedSleepTime);

      if (requestedSleepTime > 0) {
        log.info("Compacted {} in {}ms sleeping {}ms", transientRange, t2 - t1, sleepTime);
        schedExecutor.schedule(new CompactTask(transientRange, requestedSleepTime, multiplier),
            sleepTime, TimeUnit.MILLISECONDS);
      } else {
        log.info("Compacted {} in {}ms", transientRange, t2 - t1);
      }
    }