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);
}
}
}