public static void compactTransient()

in modules/accumulo/src/main/java/org/apache/fluo/recipes/accumulo/ops/TableOperations.java [113:129]

• 15 lines of code
• 2 McCabe index (conditional complexity)

  public static void compactTransient(FluoConfiguration fluoConfig) throws Exception {
    try (AccumuloClient aclient = getClient(fluoConfig);
        FluoClient fclient = FluoFactory.newClient(fluoConfig)) {
      SimpleConfiguration appConfig = fclient.getAppConfiguration();

      TransientRegistry transientRegistry = new TransientRegistry(appConfig);
      List<RowRange> ranges = transientRegistry.getTransientRanges();

      for (RowRange r : ranges) {
        long t1 = System.currentTimeMillis();
        aclient.tableOperations().compact(fluoConfig.getAccumuloTable(),
            new Text(r.getStart().toArray()), new Text(r.getEnd().toArray()), true, true);
        long t2 = System.currentTimeMillis();
        logger.info("Compacted {} in {}ms", r, (t2 - t1));
      }
    }
  }