SAMOA-43: Update WriteArffFile
Project: http://git-wip-us.apache.org/repos/asf/incubator-samoa/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-samoa/commit/f9db1f27 Tree: http://git-wip-us.apache.org/repos/asf/incubator-samoa/tree/f9db1f27 Diff: http://git-wip-us.apache.org/repos/asf/incubator-samoa/diff/f9db1f27 Branch: refs/heads/master Commit: f9db1f2718958e42fb7a0019a4b3ddee17496821 Parents: e1b63e5 Author: abifet <[email protected]> Authored: Tue Sep 15 11:27:34 2015 +0200 Committer: Albert Bifet <[email protected]> Committed: Tue Mar 15 21:37:37 2016 +0100 ---------------------------------------------------------------------- samoa-api/src/main/java/org/apache/samoa/tasks/WriteArffFile.java | 3 +++ 1 file changed, 3 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-samoa/blob/f9db1f27/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.InstanceStream; 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 class WriteArffFile implements Task, Configurable { preqSource.setMaxNumInstances(this.maxInstancesOption.getValue()); builder.addEntranceProcessor(preqSource); + Stream sourcePiOutputStream = builder.createStream(preqSource); + File destFile = this.arffFileOption.getFile(); if (destFile != null) { try {
