public static void main()

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


  public static void main(String[] args) throws Exception {

    if ((args.length == 1 && args[0].startsWith("-h")) || (args.length > 2)) {
      System.out
          .println("Usage : " + CompactTransient.class.getName() + " [<interval> [<multiplier>]]");

      System.exit(-1);
    }

    int interval = 0;
    double multiplier = 3;

    if (args.length >= 1) {
      interval = Integer.parseInt(args[0]);
      if (args.length == 2) {
        multiplier = Double.parseDouble(args[1]);
      }
    }

    if (interval > 0) {
      schedExecutor = Executors.newScheduledThreadPool(1);
    }

    List<RowRange> transientRanges;

    try (FluoClient client = FluoFactory.newClient(fluoConfig)) {
      SimpleConfiguration appConfig = client.getAppConfiguration();

      TransientRegistry tr = new TransientRegistry(appConfig);

      transientRanges = tr.getTransientRanges();

      for (RowRange transientRange : transientRanges) {
        if (interval > 0) {
          schedExecutor.execute(new CompactTask(transientRange, interval * 1000, multiplier));
        } else {
          new CompactTask(transientRange, 0, 0).run();
        }
      }
    }

    if (interval > 0) {
      while (true) {
        Thread.sleep(10000);
      }
    }
  }