commit 9b8ebcb359c7d3e2bd2c1490afd57b639a37b2af
author Mike Walch <mwalch@apache.org> Thu Oct 13 15:33:16 2016 -0400
committer GitHub <noreply@github.com> Thu Oct 13 15:33:16 2016 -0400
tree 4168ab60df21bd0c2672afdd0eb92979bab6801c
parent 2f23b0d9d3d3140339e4140ff252cdcf46f95512
parent 7838b5c117c9a31fe26b33c8e3e98b69cee33176

Merge pull request #33 from keith-turner/translate-consumer

update for latest

pom.xml

diff --git a/pom.xml b/pom.xml
index f802919..6e3ab29 100644
--- a/pom.xml
+++ b/pom.xml
@@ -12,8 +12,8 @@
 
   <properties>
     <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
-    <accumulo.version>1.6.1</accumulo.version>
-    <fluo.version>1.0.0-incubating-SNAPSHOT</fluo.version>
+    <accumulo.version>1.7.2</accumulo.version>
+    <fluo.version>1.0.0-incubating</fluo.version>
     <fluo-recipes.version>1.0.0-incubating-SNAPSHOT</fluo-recipes.version>
   </properties>
 

src/main/java/phrasecount/PhraseExporter.java

diff --git a/src/main/java/phrasecount/PhraseExporter.java b/src/main/java/phrasecount/PhraseExporter.java
index ad56645..5aec44a 100644
--- a/src/main/java/phrasecount/PhraseExporter.java
+++ b/src/main/java/phrasecount/PhraseExporter.java
@@ -1,7 +1,6 @@
 package phrasecount;
 
-import java.util.Collection;
-import java.util.Collections;
+import java.util.function.Consumer;
 
 import org.apache.accumulo.core.data.Mutation;
 import org.apache.fluo.recipes.accumulo.export.AccumuloExporter;
@@ -16,10 +15,10 @@
 public class PhraseExporter extends AccumuloExporter<String, Counts> {
 
   @Override
-  protected Collection<Mutation> translate(SequencedExport<String, Counts> export) {
+  protected void translate(SequencedExport<String, Counts> export, Consumer<Mutation> consumer) {
     String phrase = export.getKey();
     long seq = export.getSequence();
     Counts counts = export.getValue();
-    return Collections.singletonList(PhraseCountTable.createMutation(phrase, seq, counts));
+    consumer.accept(PhraseCountTable.createMutation(phrase, seq, counts));
   }
 }