commit de704cede0cb2e7e6e7ca8b63b1a0fdd6c40eaf5
author abifet <abifet@gmail.com> Tue Sep 15 11:27:34 2015 +0200
committer Albert Bifet <abifet@gmail.com> Wed Mar 16 15:33:36 2016 +0100
tree d92624a4932a4f9b777aa5086d615fde2486ed84
parent 4851dd9fd515c11eb212ac340fe0a536a6dd1e73

SAMOA-43: Update WriteArffFile

samoa-api/src/main/java/org/apache/samoa/tasks/WriteArffFile.java

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
index d792b11..12fc269 100644
--- 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 @@
         preqSource.setMaxNumInstances(this.maxInstancesOption.getValue());
         builder.addEntranceProcessor(preqSource);
 
+        Stream sourcePiOutputStream = builder.createStream(preqSource);
+
         File destFile = this.arffFileOption.getFile();
         if (destFile != null) {
             try {