Skip to content

Commit 1bd1012

Browse files
committed
SAMOA-14: Move all streams under single package
1 parent dc2b7bc commit 1bd1012

16 files changed

+22
-27
lines changed

samoa-api/src/main/java/org/apache/samoa/streams/ClusteringEntranceProcessor.java

+2-3
Original file line numberDiff line numberDiff line change
@@ -32,9 +32,8 @@
3232
import org.apache.samoa.moa.cluster.Clustering;
3333
import org.apache.samoa.moa.core.DataPoint;
3434
import org.apache.samoa.moa.options.AbstractOptionHandler;
35-
import org.apache.samoa.moa.streams.InstanceStream;
36-
import org.apache.samoa.moa.streams.clustering.ClusteringStream;
37-
import org.apache.samoa.moa.streams.clustering.RandomRBFGeneratorEvents;
35+
import org.apache.samoa.streams.clustering.ClusteringStream;
36+
import org.apache.samoa.streams.clustering.RandomRBFGeneratorEvents;
3837
import org.slf4j.Logger;
3938
import org.slf4j.LoggerFactory;
4039

samoa-api/src/main/java/org/apache/samoa/moa/streams/ExampleStream.java renamed to samoa-api/src/main/java/org/apache/samoa/streams/ExampleStream.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package org.apache.samoa.moa.streams;
1+
package org.apache.samoa.streams;
22

33
/*
44
* #%L

samoa-api/src/main/java/org/apache/samoa/streams/FileStream.java

-1
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,6 @@
3131
import org.apache.samoa.moa.core.InstanceExample;
3232
import org.apache.samoa.moa.core.ObjectRepository;
3333
import org.apache.samoa.moa.options.AbstractOptionHandler;
34-
import org.apache.samoa.moa.streams.InstanceStream;
3534
import org.apache.samoa.moa.tasks.TaskMonitor;
3635
import org.apache.samoa.streams.fs.FileStreamSource;
3736

samoa-api/src/main/java/org/apache/samoa/moa/streams/InstanceStream.java renamed to samoa-api/src/main/java/org/apache/samoa/streams/InstanceStream.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package org.apache.samoa.moa.streams;
1+
package org.apache.samoa.streams;
22

33
/*
44
* #%L

samoa-api/src/main/java/org/apache/samoa/streams/PrequentialSourceProcessor.java

-1
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,6 @@
3232
import org.apache.samoa.instances.Instances;
3333
import org.apache.samoa.learners.InstanceContentEvent;
3434
import org.apache.samoa.moa.options.AbstractOptionHandler;
35-
import org.apache.samoa.moa.streams.InstanceStream;
3635
import org.slf4j.Logger;
3736
import org.slf4j.LoggerFactory;
3837

samoa-api/src/main/java/org/apache/samoa/streams/StreamSource.java

-1
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,6 @@
2626

2727
import org.apache.samoa.instances.Instance;
2828
import org.apache.samoa.moa.core.Example;
29-
import org.apache.samoa.moa.streams.InstanceStream;
3029

3130
/**
3231
* The Class StreamSource.

samoa-api/src/main/java/org/apache/samoa/streams/StreamSourceProcessor.java

-1
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,6 @@
2929
import org.apache.samoa.instances.Instance;
3030
import org.apache.samoa.instances.Instances;
3131
import org.apache.samoa.learners.InstanceContentEvent;
32-
import org.apache.samoa.moa.streams.InstanceStream;
3332
import org.apache.samoa.topology.Stream;
3433
import org.slf4j.Logger;
3534
import org.slf4j.LoggerFactory;

samoa-api/src/main/java/org/apache/samoa/moa/streams/clustering/ClusterEvent.java renamed to samoa-api/src/main/java/org/apache/samoa/streams/clustering/ClusterEvent.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package org.apache.samoa.moa.streams.clustering;
1+
package org.apache.samoa.streams.clustering;
22

33
/*
44
* #%L

samoa-api/src/main/java/org/apache/samoa/moa/streams/clustering/ClusterEventListener.java renamed to samoa-api/src/main/java/org/apache/samoa/streams/clustering/ClusterEventListener.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package org.apache.samoa.moa.streams.clustering;
1+
package org.apache.samoa.streams.clustering;
22

33
/*
44
* #%L

samoa-api/src/main/java/org/apache/samoa/moa/streams/clustering/ClusteringStream.java renamed to samoa-api/src/main/java/org/apache/samoa/streams/clustering/ClusteringStream.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package org.apache.samoa.moa.streams.clustering;
1+
package org.apache.samoa.streams.clustering;
22

33
/*
44
* #%L
@@ -21,7 +21,7 @@
2121
*/
2222

2323
import org.apache.samoa.moa.options.AbstractOptionHandler;
24-
import org.apache.samoa.moa.streams.InstanceStream;
24+
import org.apache.samoa.streams.InstanceStream;
2525

2626
import com.github.javacliparser.FloatOption;
2727
import com.github.javacliparser.IntOption;

samoa-api/src/main/java/org/apache/samoa/moa/streams/clustering/RandomRBFGeneratorEvents.java renamed to samoa-api/src/main/java/org/apache/samoa/streams/clustering/RandomRBFGeneratorEvents.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package org.apache.samoa.moa.streams.clustering;
1+
package org.apache.samoa.streams.clustering;
22

33
/*
44
* #%L
@@ -40,8 +40,8 @@
4040
import org.apache.samoa.moa.core.FastVector;
4141
import org.apache.samoa.moa.core.InstanceExample;
4242
import org.apache.samoa.moa.core.ObjectRepository;
43-
import org.apache.samoa.moa.streams.InstanceStream;
4443
import org.apache.samoa.moa.tasks.TaskMonitor;
44+
import org.apache.samoa.streams.InstanceStream;
4545

4646
import com.github.javacliparser.FlagOption;
4747
import com.github.javacliparser.FloatOption;

samoa-api/src/main/java/org/apache/samoa/moa/streams/generators/HyperplaneGenerator.java renamed to samoa-api/src/main/java/org/apache/samoa/streams/generators/HyperplaneGenerator.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package org.apache.samoa.moa.streams.generators;
1+
package org.apache.samoa.streams.generators;
22

33
/*
44
* #%L
@@ -32,8 +32,8 @@
3232
import org.apache.samoa.moa.core.InstanceExample;
3333
import org.apache.samoa.moa.core.ObjectRepository;
3434
import org.apache.samoa.moa.options.AbstractOptionHandler;
35-
import org.apache.samoa.moa.streams.InstanceStream;
3635
import org.apache.samoa.moa.tasks.TaskMonitor;
36+
import org.apache.samoa.streams.InstanceStream;
3737

3838
import com.github.javacliparser.FloatOption;
3939
import com.github.javacliparser.IntOption;

samoa-api/src/main/java/org/apache/samoa/moa/streams/generators/RandomTreeGenerator.java renamed to samoa-api/src/main/java/org/apache/samoa/streams/generators/RandomTreeGenerator.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package org.apache.samoa.moa.streams.generators;
1+
package org.apache.samoa.streams.generators;
22

33
/*
44
* #%L
@@ -33,8 +33,8 @@
3333
import org.apache.samoa.moa.core.InstanceExample;
3434
import org.apache.samoa.moa.core.ObjectRepository;
3535
import org.apache.samoa.moa.options.AbstractOptionHandler;
36-
import org.apache.samoa.moa.streams.InstanceStream;
3736
import org.apache.samoa.moa.tasks.TaskMonitor;
37+
import org.apache.samoa.streams.InstanceStream;
3838

3939
import com.github.javacliparser.FloatOption;
4040
import com.github.javacliparser.IntOption;

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

+3-3
Original file line numberDiff line numberDiff line change
@@ -26,10 +26,10 @@
2626
import org.apache.samoa.learners.Learner;
2727
import org.apache.samoa.learners.clusterers.simple.ClusteringDistributorProcessor;
2828
import org.apache.samoa.learners.clusterers.simple.DistributedClusterer;
29-
import org.apache.samoa.moa.streams.InstanceStream;
30-
import org.apache.samoa.moa.streams.clustering.ClusteringStream;
31-
import org.apache.samoa.moa.streams.clustering.RandomRBFGeneratorEvents;
3229
import org.apache.samoa.streams.ClusteringEntranceProcessor;
30+
import org.apache.samoa.streams.InstanceStream;
31+
import org.apache.samoa.streams.clustering.ClusteringStream;
32+
import org.apache.samoa.streams.clustering.RandomRBFGeneratorEvents;
3333
import org.apache.samoa.topology.ComponentFactory;
3434
import org.apache.samoa.topology.Stream;
3535
import org.apache.samoa.topology.Topology;

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

+2-2
Original file line numberDiff line numberDiff line change
@@ -32,9 +32,9 @@
3232
import org.apache.samoa.learners.Learner;
3333
import org.apache.samoa.learners.RegressionLearner;
3434
import org.apache.samoa.learners.classifiers.trees.VerticalHoeffdingTree;
35-
import org.apache.samoa.moa.streams.InstanceStream;
36-
import org.apache.samoa.moa.streams.generators.RandomTreeGenerator;
35+
import org.apache.samoa.streams.InstanceStream;
3736
import org.apache.samoa.streams.PrequentialSourceProcessor;
37+
import org.apache.samoa.streams.generators.RandomTreeGenerator;
3838
import org.apache.samoa.topology.ComponentFactory;
3939
import org.apache.samoa.topology.Stream;
4040
import org.apache.samoa.topology.Topology;

samoa-test/src/test/java/org/apache/samoa/TestParams.java

+3-3
Original file line numberDiff line numberDiff line change
@@ -36,18 +36,18 @@ public static class Templates {
3636

3737
public final static String PREQEVAL_VHT_RANDOMTREE = "PrequentialEvaluation -d %s -i %d -f %d -w %d "
3838
+ "-l (org.apache.samoa.learners.classifiers.trees.VerticalHoeffdingTree -p 4) " +
39-
"-s (org.apache.samoa.moa.streams.generators.RandomTreeGenerator -c 2 -o 10 -u 10)";
39+
"-s (org.apache.samoa.streams.generators.RandomTreeGenerator -c 2 -o 10 -u 10)";
4040

4141
public final static String PREQEVAL_NAIVEBAYES_HYPERPLANE = "PrequentialEvaluation -d %s -i %d -f %d -w %d "
4242
+ "-l (classifiers.SingleClassifier -l org.apache.samoa.learners.classifiers.NaiveBayes) " +
43-
"-s (org.apache.samoa.moa.streams.generators.HyperplaneGenerator -c 2)";
43+
"-s (org.apache.samoa.streams.generators.HyperplaneGenerator -c 2)";
4444

4545
// setting the number of nominal attributes to zero significantly reduces
4646
// the processing time,
4747
// so that it's acceptable in a test case
4848
public final static String PREQEVAL_BAGGING_RANDOMTREE = "PrequentialEvaluation -d %s -i %d -f %d -w %d "
4949
+ "-l (org.apache.samoa.learners.classifiers.ensemble.Bagging) " +
50-
"-s (org.apache.samoa.moa.streams.generators.RandomTreeGenerator -c 2 -o 0 -u 10)";
50+
"-s (org.apache.samoa.streams.generators.RandomTreeGenerator -c 2 -o 0 -u 10)";
5151

5252
}
5353

0 commit comments

Comments
 (0)