in modules/accumulo/src/main/java/org/apache/fluo/recipes/accumulo/export/function/AccumuloExporter.java [91:102]
public void export(Iterator<SequencedExport<K, V>> t) {
ArrayList<Mutation> buffer = new ArrayList<>();
Consumer<Mutation> consumer = buffer::add;
while (t.hasNext()) {
translator.translate(t.next(), consumer);
}
if (buffer.size() > 0) {
writer.write(buffer);
}
}