This is an automated email from the ASF dual-hosted git repository.
csterling pushed a change to reference refs/pull/46/head
in repository https://gitbox.apache.org/repos/asf/incubator-samoa.git.
omit 75acd40 Code cleanups and warnings
add 4375bce SAMOA-56: Update Developers-Guide link. Fix #45
add b86ab83 SAMOA-51: Update Flink Module to v0.10.1 Fix #44
add de050f9 SAMOA-57: Remove support for S4
add 8f888b7 SAMOA-57: Fix failing test (wrong number of instances)
add c1d42d2 SAMOA-31: Remove unused Utils class Close #49
add 1bf3c02 SAMOA-28: Delete samoa-api/build directory after tests
add dc2b7bc SAMOA-14: Consolidate ARFFFileStream
add 1bd1012 SAMOA-14: Move all streams under single package
add 7a17765 SAMOA-53: Add Prequential Cross-Validation Evaluation
add bd15959 SAMOA-53: Add tests for the new prequential cv evaluation task
add 8113847 SAMOA-53: Update move all streams under single package
add 82b3ef3 SAMOA-52: Fix nominal attributes problem in VHT
add 473a419 SAMOA-43: Add TextReader
add 4851dd9 SAMOA-43: Add WriteArffFile
add de704ce SAMOA-43: Update WriteArffFile
add 0640831 SAMOA-43: Update stream import in TextGenerator
add 381e6a9 SAMOA-58: Only add fields of supported types (double, float,
long, int and enum) rather than adding and defaulting all non-enum to numeric
and failing at value parse time
add ebb3516 SAMOA-58: until we change samza to produce files with .avro
extension
add 16046cc SAMOA-58: A tentative solution to issue described in:
add 6e81a62 SAMOA-58: Issue described in
https://issues.apache.org/jira/browse/SAMOA-58 was apparently more complicated
than what was expected in previous commit. While we did succeed in replacing
the first exhausted file stream with a new one, the loader was not changed and
would return null. This rework of AvroFileStream, FileStream and ArffFileStream
hopefully cleans things up a bit and allows multi-file streams of either (Avro
or Arff) type.
add 127eaab SAMOA-58: configure don't code
add 2c60852 SAMOA-58: cherry-picked from faf branch - changes needed to
be able to read from HDFS on a YARN 2.7.1 cluster
add a6b6e2e SAMOA-58: Implementation of the standard precision, recall,
and f1-score measures for each class in a multi-class setting
add 397de94 SAMOA-58: Not sure why these still implement Learner instead
of ClassificationLearner - technically yes one could have an ensemble of
regressors or classifiers but these are not generic as currently implemented.
add c743b7e SAMOA-58: was not initializing arrays prior to use
add 1c8778e SAMOA-58: forgot to initialize support array
add e5ca1b2 SAMOA-58: need more decimal digits
add 5d131e2 SAMOA-58: adding all measurements
add 78ae8fc SAMOA-58: Needed to loop over all Union types to determine if
Union-typed field is numeric or not.
add 15df252 SAMOA-58: Filter out NaN and Inf values
add 9e174aa SAMOA-58: Refactored class index command line parameter in
Avro- and ArffFileStream up to common parent FileStream.
add a1e0376 SAMOA-58: Just because it fools compiler ...
add a342340 SAMOA-58: changes @gdfm requested
add 7ecdc4b SAMOA-58: Incorrect Samza artifact version. Samza no longer
produces separate serializers artifact. isFinite since 1.8 - changed to work
with what's available since 1.7
add bc92205 SAMOA-58: Reverting back to Samza 0.7.0 in order to keep this
pull request from exploding into a full Samza upgrade set of changes (did that
in a separate pull request which I closed for similar scope creep and
pollution) Fix #48
add 88f1753 removing gradlew s4 related stuff
add 65817f1 changed notice year to 2016
add ab411ed [maven-release-plugin] prepare release v0.4.0-incubating
add 2c26c04 [maven-release-plugin] prepare for next development iteration
add 1c858e1 SAMOA-49: Added adapter for Apache Apex
add a1cc237 Fix broken Markdown headings
add a92b303 SAMOA-70: Fix bug in DenseInstance toString method which
resulted in always writing an arff file with class equal to zero. fix #60
add 4471fe4 SAMOA-35: Add Sharding ensemble method
add dbc3aab SAMOA-68: Saving true and predicted labels to file Fix #61
add 26c2191 SAMOA-67 : Integration of MOA instances in SAMOA
add 804eac8 SAMOA-65: Apache Kafka integration components for SAMOA Fix
#59
add 6e6bb18 SAMOA-71: fixes concurrency issues in
HorizontalAMRulesRegressor and storm tests Fix #68
add b4a9709 Code cleanups and warnings
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
reference are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (75acd40)
\
N -- N -- N refs/pull/46/head (b4a9709)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.gitignore | 31 +-
.travis.yml | 10 -
NOTICE | 2 +-
README.md | 17 +-
bin/s4-build/README.md | 3 -
bin/s4-build/gradle-wrapper-1.4.properties | 25 --
bin/s4-build/gradlew | 164 -------
bin/samoa | 87 +++-
bin/samoa-apex.properties | 53 +++
bin/samoa-storm.properties | 2 +-
pom.xml | 20 +-
samoa-apex/README.md | 64 +++
{samoa-storm => samoa-apex}/pom.xml | 85 ++--
.../java/org/apache/samoa/apex/ApexDoTask.java | 75 ++++
.../java/org/apache/samoa/apex/ApexSamoaUtils.java | 62 +++
.../org/apache/samoa/apex/LocalApexDoTask.java | 65 +++
.../org/apache/samoa/apex/StreamingAppFactory.java | 52 +++
.../apex/topology/impl/ApexComponentFactory.java | 29 +-
.../topology/impl/ApexEntranceProcessingItem.java | 69 +++
.../apex/topology/impl/ApexInputOperator.java | 91 ++++
.../samoa/apex/topology/impl/ApexOperator.java | 158 +++++++
.../apex/topology/impl/ApexProcessingItem.java | 113 +++++
.../samoa/apex/topology/impl/ApexStream.java | 48 +-
.../samoa/apex/topology/impl/ApexStreamUtils.java | 135 ++++++
.../apache/samoa/apex/topology/impl/ApexTask.java | 151 +++++++
.../samoa/apex/topology/impl/ApexTopology.java | 71 +++
.../samoa/apex/topology/impl/ApexTopologyNode.java | 23 +-
.../impl/DefaultInputPortSerializable.java | 18 +-
.../impl/DefaultOutputPortSerializable.java | 18 +-
.../topology/impl/DelayOperatorSerializable.java | 60 +++
samoa-apex/src/main/resources/log4j.properties | 42 ++
.../java/org/apache/samoa/apex/AlgosTestApex.java | 23 +-
samoa-apex/src/test/resources/log4j.properties | 42 ++
samoa-api/pom.xml | 258 ++++++-----
.../BasicClassificationPerformanceEvaluator.java | 100 ++++-
.../BasicRegressionPerformanceEvaluator.java | 46 +-
.../EvaluationDistributorProcessor.java} | 82 ++--
...torProcessor.java => EvaluatorCVProcessor.java} | 144 ++++--
.../samoa/evaluation/EvaluatorProcessor.java | 72 ++-
.../F1ClassificationPerformanceEvaluator.java | 195 +++++++++
.../samoa/evaluation/PerformanceEvaluator.java | 10 +-
.../WindowClassificationPerformanceEvaluator.java | 43 +-
.../learners/classifiers/SingleClassifier.java | 3 +-
.../classifiers/ensemble/AdaptiveBagging.java | 3 +-
.../learners/classifiers/ensemble/Bagging.java | 6 +-
.../learners/classifiers/ensemble/Boosting.java | 3 +-
.../ensemble/{Bagging.java => Sharding.java} | 48 +-
...ssor.java => ShardingDistributorProcessor.java} | 63 +--
.../rules/distributed/AMRRuleSetProcessor.java | 7 +-
.../classifiers/trees/ActiveLearningNode.java | 2 +
.../trees/ModelAggregatorProcessor.java | 39 +-
.../org/apache/samoa/moa/core/Measurement.java | 9 +-
.../main/java/org/apache/samoa/moa/core/Vote.java | 86 ++++
.../apache/samoa/moa/evaluation/LearningCurve.java | 62 +++
.../apache/samoa/moa/streams/ArffFileStream.java | 200 ---------
.../org/apache/samoa/streams/ArffFileStream.java | 41 +-
.../samoa/{moa => }/streams/AvroFileStream.java | 16 +-
.../samoa/streams/ClusteringEntranceProcessor.java | 5 +-
.../samoa/{moa => }/streams/ExampleStream.java | 2 +-
.../java/org/apache/samoa/streams/FileStream.java | 72 +--
.../samoa/{moa => }/streams/InstanceStream.java | 2 +-
.../samoa/streams/PrequentialSourceProcessor.java | 1 -
.../org/apache/samoa/streams/StreamSource.java | 1 -
.../samoa/streams/StreamSourceProcessor.java | 1 -
.../org/apache/samoa/streams/TextGenerator.java | 205 +++++++++
.../{moa => }/streams/clustering/ClusterEvent.java | 2 +-
.../streams/clustering/ClusterEventListener.java | 2 +-
.../streams/clustering/ClusteringStream.java | 4 +-
.../clustering/RandomRBFGeneratorEvents.java | 4 +-
.../samoa/streams/fs/HDFSFileStreamSource.java | 16 +-
.../streams/generators/HyperplaneGenerator.java | 4 +-
.../streams/generators/RandomTreeGenerator.java | 4 +-
.../samoa/streams/kafka/KafkaConsumerThread.java | 174 ++++++++
.../samoa/streams/kafka/KafkaDeserializer.java | 51 +++
.../streams/kafka/KafkaDestinationProcessor.java | 100 +++++
.../streams/kafka/KafkaEntranceProcessor.java | 126 ++++++
.../samoa/streams/kafka/KafkaSerializer.java | 52 +++
.../org/apache/samoa/streams/kafka/KafkaUtils.java | 142 ++++++
.../apache/samoa/tasks/ClusteringEvaluation.java | 6 +-
.../java/org/apache/samoa/tasks/KafkaTask.java | 199 +++++++++
.../samoa/tasks/PrequentialCVEvaluation.java | 166 +++++++
.../apache/samoa/tasks/PrequentialEvaluation.java | 31 +-
.../java/org/apache/samoa/tasks/WriteArffFile.java | 145 ++++++
.../main/java/org/apache/samoa/utils/Utils.java | 183 --------
.../services/org.apache.hadoop.fs.FileSystem | 2 +
samoa-api/src/main/resources/kafka.avsc | 106 +++++
.../samoa/streams/fs/HDFSFileStreamSourceTest.java | 24 +-
.../kafka/KafkaDestinationProcessorTest.java | 175 ++++++++
.../streams/kafka/KafkaEntranceProcessorTest.java | 185 ++++++++
.../apache/samoa/streams/kafka/KafkaUtilsTest.java | 247 +++++++++++
.../samoa/streams/kafka/OosTestSerializer.java | 77 ++++
.../samoa/streams/kafka/TestUtilsForKafka.java | 136 ++++++
samoa-flink/pom.xml | 4 +-
.../java/org/apache/samoa/flink/FlinkDoTask.java | 7 -
.../{CircleDetection.java => CycleDetection.java} | 14 +-
.../java/org/apache/samoa/flink/helpers/Utils.java | 4 +-
.../flink/topology/impl/FlinkProcessingItem.java | 55 ++-
.../samoa/flink/topology/impl/FlinkStream.java | 32 +-
.../samoa/flink/topology/impl/FlinkTopology.java | 278 ++++++------
samoa-instances/pom.xml | 2 +-
.../org/apache/samoa/instances/ArffLoader.java | 456 +++++++++++--------
.../java/org/apache/samoa/instances/Attribute.java | 188 +++++---
.../samoa/instances/AttributesInformation.java | 152 +++++++
.../apache/samoa/instances/AvroBinaryLoader.java | 3 -
.../org/apache/samoa/instances/AvroJsonLoader.java | 3 -
.../org/apache/samoa/instances/AvroLoader.java | 40 +-
.../org/apache/samoa/instances/DenseInstance.java | 61 +--
.../apache/samoa/instances/DenseInstanceData.java | 103 ++++-
.../java/org/apache/samoa/instances/Instance.java | 316 ++++++++++++--
.../org/apache/samoa/instances/InstanceData.java | 76 +++-
.../org/apache/samoa/instances/InstanceImpl.java | 483 ++++++++++++++++++++
.../samoa/instances/InstanceInformation.java | 158 +++++--
.../java/org/apache/samoa/instances/Instances.java | 484 ++++++++++++++++++---
.../apache/samoa/instances/InstancesHeader.java | 60 +--
.../java/org/apache/samoa/instances/Loader.java | 6 -
.../apache/samoa/instances/MultiLabelInstance.java | 13 +-
.../samoa/instances/MultiLabelPrediction.java | 139 ++++++
.../samoa/instances/MultiTargetArffLoader.java | 32 +-
.../org/apache/samoa/instances/Prediction.java | 110 +++++
.../java/org/apache/samoa/instances/Range.java | 114 +++++
.../samoa/instances/SingleClassInstanceData.java | 86 ----
.../samoa/instances/SingleLabelInstance.java | 260 -----------
.../org/apache/samoa/instances/SparseInstance.java | 37 +-
.../apache/samoa/instances/SparseInstanceData.java | 165 ++++++-
.../java/org/apache/samoa/instances/Utils.java | 2 +-
samoa-local/pom.xml | 2 +-
.../src/test/java/org/apache/samoa/AlgosTest.java | 23 +
samoa-s4/pom.xml | 136 ------
samoa-s4/samoa-s4-adapter/pom.xml | 54 ---
.../java/samoa/topology/adapter/S4AdapterApp.java | 45 --
.../topology/adapter/S4EntranceProcessingItem.java | 74 ----
samoa-s4/src/main/assembly/samoa-s4.xml | 78 ----
.../samoa/topology/impl/S4ComponentFactory.java | 97 -----
.../org/apache/samoa/topology/impl/S4DoTask.java | 268 ------------
.../topology/impl/S4EntranceProcessingItem.java | 119 -----
.../org/apache/samoa/topology/impl/S4Event.java | 91 ----
.../samoa/topology/impl/S4ProcessingItem.java | 186 --------
.../org/apache/samoa/topology/impl/S4Stream.java | 184 --------
.../apache/samoa/topology/impl/S4Submitter.java | 144 ------
.../org/apache/samoa/topology/impl/S4Topology.java | 63 ---
.../samoa/topology/impl/SamoaSerializer.java | 99 -----
samoa-samza/pom.xml | 2 +-
.../java/org/apache/samoa/utils/SystemsUtils.java | 20 +-
samoa-storm/pom.xml | 2 +-
.../src/test/java/org/apache/samoa/AlgosTest.java | 27 +-
samoa-test/pom.xml | 2 +-
.../src/test/java/org/apache/samoa/TestParams.java | 60 ++-
.../src/test/java/org/apache/samoa/TestUtils.java | 88 ++--
samoa-threads/pom.xml | 2 +-
.../src/test/java/org/apache/samoa/AlgosTest.java | 4 +-
150 files changed, 7998 insertions(+), 3913 deletions(-)
delete mode 100644 bin/s4-build/README.md
delete mode 100644 bin/s4-build/gradle-wrapper-1.4.properties
delete mode 100755 bin/s4-build/gradlew
create mode 100644 bin/samoa-apex.properties
create mode 100644 samoa-apex/README.md
copy {samoa-storm => samoa-apex}/pom.xml (63%)
create mode 100644
samoa-apex/src/main/java/org/apache/samoa/apex/ApexDoTask.java
create mode 100644
samoa-apex/src/main/java/org/apache/samoa/apex/ApexSamoaUtils.java
create mode 100644
samoa-apex/src/main/java/org/apache/samoa/apex/LocalApexDoTask.java
create mode 100644
samoa-apex/src/main/java/org/apache/samoa/apex/StreamingAppFactory.java
copy
samoa-storm/src/main/java/org/apache/samoa/topology/impl/StormComponentFactory.java
=>
samoa-apex/src/main/java/org/apache/samoa/apex/topology/impl/ApexComponentFactory.java
(75%)
create mode 100644
samoa-apex/src/main/java/org/apache/samoa/apex/topology/impl/ApexEntranceProcessingItem.java
create mode 100644
samoa-apex/src/main/java/org/apache/samoa/apex/topology/impl/ApexInputOperator.java
create mode 100644
samoa-apex/src/main/java/org/apache/samoa/apex/topology/impl/ApexOperator.java
create mode 100644
samoa-apex/src/main/java/org/apache/samoa/apex/topology/impl/ApexProcessingItem.java
copy
samoa-storm/src/main/java/org/apache/samoa/topology/impl/StormBoltStream.java
=> samoa-apex/src/main/java/org/apache/samoa/apex/topology/impl/ApexStream.java
(52%)
create mode 100644
samoa-apex/src/main/java/org/apache/samoa/apex/topology/impl/ApexStreamUtils.java
create mode 100644
samoa-apex/src/main/java/org/apache/samoa/apex/topology/impl/ApexTask.java
create mode 100644
samoa-apex/src/main/java/org/apache/samoa/apex/topology/impl/ApexTopology.java
rename
samoa-s4/src/main/java/org/apache/samoa/topology/impl/SamoaSerializerModule.java
=>
samoa-apex/src/main/java/org/apache/samoa/apex/topology/impl/ApexTopologyNode.java
(67%)
copy
samoa-storm/src/main/java/org/apache/samoa/topology/impl/StormTopologyNode.java
=>
samoa-apex/src/main/java/org/apache/samoa/apex/topology/impl/DefaultInputPortSerializable.java
(63%)
copy
samoa-storm/src/main/java/org/apache/samoa/topology/impl/StormTopologyNode.java
=>
samoa-apex/src/main/java/org/apache/samoa/apex/topology/impl/DefaultOutputPortSerializable.java
(63%)
create mode 100644
samoa-apex/src/main/java/org/apache/samoa/apex/topology/impl/DelayOperatorSerializable.java
create mode 100644 samoa-apex/src/main/resources/log4j.properties
copy samoa-storm/src/test/java/org/apache/samoa/AlgosTest.java =>
samoa-apex/src/test/java/org/apache/samoa/apex/AlgosTestApex.java (74%)
create mode 100644 samoa-apex/src/test/resources/log4j.properties
copy
samoa-api/src/main/java/org/apache/samoa/{learners/classifiers/ensemble/BaggingDistributorProcessor.java
=> evaluation/EvaluationDistributorProcessor.java} (59%)
copy
samoa-api/src/main/java/org/apache/samoa/evaluation/{EvaluatorProcessor.java =>
EvaluatorCVProcessor.java} (58%)
create mode 100644
samoa-api/src/main/java/org/apache/samoa/evaluation/F1ClassificationPerformanceEvaluator.java
copy
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/ensemble/{Bagging.java
=> Sharding.java} (76%)
copy
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/ensemble/{BaggingDistributorProcessor.java
=> ShardingDistributorProcessor.java} (74%)
create mode 100644 samoa-api/src/main/java/org/apache/samoa/moa/core/Vote.java
delete mode 100644
samoa-api/src/main/java/org/apache/samoa/moa/streams/ArffFileStream.java
rename samoa-api/src/main/java/org/apache/samoa/{moa =>
}/streams/AvroFileStream.java (93%)
rename samoa-api/src/main/java/org/apache/samoa/{moa =>
}/streams/ExampleStream.java (98%)
rename samoa-api/src/main/java/org/apache/samoa/{moa =>
}/streams/InstanceStream.java (96%)
create mode 100644
samoa-api/src/main/java/org/apache/samoa/streams/TextGenerator.java
rename samoa-api/src/main/java/org/apache/samoa/{moa =>
}/streams/clustering/ClusterEvent.java (95%)
rename samoa-api/src/main/java/org/apache/samoa/{moa =>
}/streams/clustering/ClusterEventListener.java (94%)
rename samoa-api/src/main/java/org/apache/samoa/{moa =>
}/streams/clustering/ClusteringStream.java (94%)
rename samoa-api/src/main/java/org/apache/samoa/{moa =>
}/streams/clustering/RandomRBFGeneratorEvents.java (99%)
rename samoa-api/src/main/java/org/apache/samoa/{moa =>
}/streams/generators/HyperplaneGenerator.java (98%)
rename samoa-api/src/main/java/org/apache/samoa/{moa =>
}/streams/generators/RandomTreeGenerator.java (98%)
create mode 100644
samoa-api/src/main/java/org/apache/samoa/streams/kafka/KafkaConsumerThread.java
create mode 100644
samoa-api/src/main/java/org/apache/samoa/streams/kafka/KafkaDeserializer.java
create mode 100644
samoa-api/src/main/java/org/apache/samoa/streams/kafka/KafkaDestinationProcessor.java
create mode 100644
samoa-api/src/main/java/org/apache/samoa/streams/kafka/KafkaEntranceProcessor.java
create mode 100644
samoa-api/src/main/java/org/apache/samoa/streams/kafka/KafkaSerializer.java
create mode 100644
samoa-api/src/main/java/org/apache/samoa/streams/kafka/KafkaUtils.java
create mode 100644
samoa-api/src/main/java/org/apache/samoa/tasks/KafkaTask.java
create mode 100644
samoa-api/src/main/java/org/apache/samoa/tasks/PrequentialCVEvaluation.java
create mode 100644
samoa-api/src/main/java/org/apache/samoa/tasks/WriteArffFile.java
delete mode 100644 samoa-api/src/main/java/org/apache/samoa/utils/Utils.java
create mode 100644
samoa-api/src/main/resources/META-INF/services/org.apache.hadoop.fs.FileSystem
create mode 100644 samoa-api/src/main/resources/kafka.avsc
create mode 100644
samoa-api/src/test/java/org/apache/samoa/streams/kafka/KafkaDestinationProcessorTest.java
create mode 100644
samoa-api/src/test/java/org/apache/samoa/streams/kafka/KafkaEntranceProcessorTest.java
create mode 100644
samoa-api/src/test/java/org/apache/samoa/streams/kafka/KafkaUtilsTest.java
create mode 100644
samoa-api/src/test/java/org/apache/samoa/streams/kafka/OosTestSerializer.java
create mode 100644
samoa-api/src/test/java/org/apache/samoa/streams/kafka/TestUtilsForKafka.java
rename
samoa-flink/src/main/java/org/apache/samoa/flink/helpers/{CircleDetection.java
=> CycleDetection.java} (85%)
create mode 100644
samoa-instances/src/main/java/org/apache/samoa/instances/AttributesInformation.java
create mode 100644
samoa-instances/src/main/java/org/apache/samoa/instances/InstanceImpl.java
rename
samoa-s4/samoa-s4-adapter/src/main/java/samoa/topology/adapter/package-info.java
=>
samoa-instances/src/main/java/org/apache/samoa/instances/MultiLabelInstance.java
(87%)
create mode 100644
samoa-instances/src/main/java/org/apache/samoa/instances/MultiLabelPrediction.java
copy samoa-api/src/main/java/org/apache/samoa/moa/core/InstanceExample.java =>
samoa-instances/src/main/java/org/apache/samoa/instances/MultiTargetArffLoader.java
(54%)
create mode 100644
samoa-instances/src/main/java/org/apache/samoa/instances/Prediction.java
create mode 100644
samoa-instances/src/main/java/org/apache/samoa/instances/Range.java
delete mode 100644
samoa-instances/src/main/java/org/apache/samoa/instances/SingleClassInstanceData.java
delete mode 100644
samoa-instances/src/main/java/org/apache/samoa/instances/SingleLabelInstance.java
delete mode 100644 samoa-s4/pom.xml
delete mode 100644 samoa-s4/samoa-s4-adapter/pom.xml
delete mode 100644
samoa-s4/samoa-s4-adapter/src/main/java/samoa/topology/adapter/S4AdapterApp.java
delete mode 100644
samoa-s4/samoa-s4-adapter/src/main/java/samoa/topology/adapter/S4EntranceProcessingItem.java
delete mode 100644 samoa-s4/src/main/assembly/samoa-s4.xml
delete mode 100644
samoa-s4/src/main/java/org/apache/samoa/topology/impl/S4ComponentFactory.java
delete mode 100644
samoa-s4/src/main/java/org/apache/samoa/topology/impl/S4DoTask.java
delete mode 100644
samoa-s4/src/main/java/org/apache/samoa/topology/impl/S4EntranceProcessingItem.java
delete mode 100644
samoa-s4/src/main/java/org/apache/samoa/topology/impl/S4Event.java
delete mode 100644
samoa-s4/src/main/java/org/apache/samoa/topology/impl/S4ProcessingItem.java
delete mode 100644
samoa-s4/src/main/java/org/apache/samoa/topology/impl/S4Stream.java
delete mode 100644
samoa-s4/src/main/java/org/apache/samoa/topology/impl/S4Submitter.java
delete mode 100644
samoa-s4/src/main/java/org/apache/samoa/topology/impl/S4Topology.java
delete mode 100644
samoa-s4/src/main/java/org/apache/samoa/topology/impl/SamoaSerializer.java
