Repository: incubator-samoa Updated Branches: refs/heads/master 82b3ef370 -> de704cede
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/de704ced Tree: http://git-wip-us.apache.org/repos/asf/incubator-samoa/tree/de704ced Diff: http://git-wip-us.apache.org/repos/asf/incubator-samoa/diff/de704ced Branch: refs/heads/master Commit: de704cede0cb2e7e6e7ca8b63b1a0fdd6c40eaf5 Parents: 4851dd9 Author: abifet <[email protected]> Authored: Tue Sep 15 11:27:34 2015 +0200 Committer: Albert Bifet <[email protected]> Committed: Wed Mar 16 15:33:36 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/de704ced/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 {
