public void export()

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