SAMOA-43: Update WriteArffFile

apache · Mar 15, 2016 · f9db1f2 · f9db1f2
1 parent e1b63e5
commit f9db1f2
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/samoa-api/src/main/java/org/apache/samoa/tasks/WriteArffFile.java b/samoa-api/src/main/java/org/apache/samoa/tasks/WriteArffFile.java
@@ -26,6 +26,7 @@
 import org.apache.samoa.moa.streams.clustering.RandomRBFGeneratorEvents;
 import org.apache.samoa.streams.PrequentialSourceProcessor;
 import org.apache.samoa.topology.ComponentFactory;
+import org.apache.samoa.topology.Stream;
 import org.apache.samoa.topology.Topology;
 import org.apache.samoa.topology.TopologyBuilder;
 import org.slf4j.Logger;
@@ -85,6 +86,8 @@ public void init() {
         preqSource.setMaxNumInstances(this.maxInstancesOption.getValue());
         builder.addEntranceProcessor(preqSource);
 
+        Stream sourcePiOutputStream = builder.createStream(preqSource);
+
         File destFile = this.arffFileOption.getFile();
         if (destFile != null) {
             try {