in stresso/src/main/java/stresso/trie/Split.java [79:97]
private static void optimizeAccumulo(TableOperations tableOps, String table, String tableProps)
throws Exception {
Properties tprops = new Properties();
tprops.load(new ByteArrayInputStream(tableProps.getBytes(StandardCharsets.UTF_8)));
Set<Entry<Object, Object>> es = tprops.entrySet();
for (Entry<Object, Object> e : es) {
tableOps.setProperty(table, e.getKey().toString(), e.getValue().toString());
}
try {
tableOps.setProperty(table, "table.durability", "flush");
tableOps.removeProperty("accumulo.metadata", "table.durability");
tableOps.removeProperty("accumulo.root", "table.durability");
} catch (AccumuloException e) {
System.err.println(
"Unable to set durability settings (error expected in Accumulo 1.6) : " + e.getMessage());
}
}