Path	Lines of Code
samoa-api/src/main/java/org/apache/samoa/core/ContentEvent.java	6
samoa-api/src/main/java/org/apache/samoa/core/DoubleVector.java	78
samoa-api/src/main/java/org/apache/samoa/core/EntranceProcessor.java	9
samoa-api/src/main/java/org/apache/samoa/core/Globals.java	22
samoa-api/src/main/java/org/apache/samoa/core/Processor.java	8
samoa-api/src/main/java/org/apache/samoa/core/SerializableInstance.java	15
samoa-api/src/main/java/org/apache/samoa/evaluation/BasicClassificationPerformanceEvaluator.java	143
samoa-api/src/main/java/org/apache/samoa/evaluation/BasicRegressionPerformanceEvaluator.java	108
samoa-api/src/main/java/org/apache/samoa/evaluation/ClassificationPerformanceEvaluator.java	3
samoa-api/src/main/java/org/apache/samoa/evaluation/ClusteringEvaluationContentEvent.java	38
samoa-api/src/main/java/org/apache/samoa/evaluation/ClusteringEvaluatorProcessor.java	227
samoa-api/src/main/java/org/apache/samoa/evaluation/ClusteringResultContentEvent.java	31
samoa-api/src/main/java/org/apache/samoa/evaluation/EvaluationDistributorProcessor.java	98
samoa-api/src/main/java/org/apache/samoa/evaluation/EvaluatorCVProcessor.java	208
samoa-api/src/main/java/org/apache/samoa/evaluation/EvaluatorProcessor.java	209
samoa-api/src/main/java/org/apache/samoa/evaluation/F1ClassificationPerformanceEvaluator.java	144
samoa-api/src/main/java/org/apache/samoa/evaluation/PerformanceEvaluator.java	12
samoa-api/src/main/java/org/apache/samoa/evaluation/RegressionPerformanceEvaluator.java	3
samoa-api/src/main/java/org/apache/samoa/evaluation/TimeClassificationPerformanceEvaluator.java	357
samoa-api/src/main/java/org/apache/samoa/evaluation/WindowClassificationPerformanceEvaluator.java	150
samoa-api/src/main/java/org/apache/samoa/evaluation/WindowEstimator.java	35
samoa-api/src/main/java/org/apache/samoa/evaluation/measures/CMM.java	322
samoa-api/src/main/java/org/apache/samoa/evaluation/measures/CMM_GTAnalysis.java	423
samoa-api/src/main/java/org/apache/samoa/evaluation/measures/EntropyCollection.java	125
samoa-api/src/main/java/org/apache/samoa/evaluation/measures/F1.java	72
samoa-api/src/main/java/org/apache/samoa/evaluation/measures/General.java	132
samoa-api/src/main/java/org/apache/samoa/evaluation/measures/SSQ.java	60
samoa-api/src/main/java/org/apache/samoa/evaluation/measures/Separation.java	76
samoa-api/src/main/java/org/apache/samoa/evaluation/measures/SilhouetteCoefficient.java	86
samoa-api/src/main/java/org/apache/samoa/evaluation/measures/StatisticalCollection.java	133
samoa-api/src/main/java/org/apache/samoa/learners/AdaptiveLearner.java	6
samoa-api/src/main/java/org/apache/samoa/learners/ClassificationLearner.java	4
samoa-api/src/main/java/org/apache/samoa/learners/InstanceContent.java	76
samoa-api/src/main/java/org/apache/samoa/learners/InstanceContentEvent.java	78
samoa-api/src/main/java/org/apache/samoa/learners/InstancesContentEvent.java	49
samoa-api/src/main/java/org/apache/samoa/learners/Learner.java	12
samoa-api/src/main/java/org/apache/samoa/learners/RegressionLearner.java	4
samoa-api/src/main/java/org/apache/samoa/learners/ResultContentEvent.java	87
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/LocalLearner.java	13
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/LocalLearnerProcessor.java	103
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/NaiveBayes.java	110
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/SimpleClassifierAdapter.java	64
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/SingleClassifier.java	57
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/ensemble/AdaptiveBagging.java	82
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/ensemble/Bagging.java	77
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/ensemble/BaggingDistributorProcessor.java	82
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/ensemble/BoostMAProcessor.java	182
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/ensemble/BoostVHT.java	125
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/ensemble/BoostVHTProcessor.java	297
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/ensemble/Boosting.java	64
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/ensemble/BoostingDistributorProcessor.java	7
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/ensemble/BoostingPredictionCombinerProcessor.java	103
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/ensemble/PredictionCombinerProcessor.java	95
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/ensemble/Sharding.java	76
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/ensemble/ShardingDistributorProcessor.java	72
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/rules/AMRulesRegressor.java	114
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/rules/HorizontalAMRulesRegressor.java	155
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/rules/VerticalAMRulesRegressor.java	131
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/rules/centralized/AMRulesRegressorProcessor.java	332
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/rules/common/ActiveRule.java	123
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/rules/common/LearningRule.java	57
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/rules/common/NonLearningRule.java	11
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/rules/common/PassiveRule.java	25
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/rules/common/Perceptron.java	321
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/rules/common/Rule.java	56
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/rules/common/RuleActiveLearningNode.java	4
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/rules/common/RuleActiveRegressionNode.java	200
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/rules/common/RulePassiveLearningNode.java	3
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/rules/common/RulePassiveRegressionNode.java	30
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/rules/common/RuleRegressionNode.java	184
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/rules/common/RuleSplitNode.java	29
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/rules/common/TargetMean.java	139
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/rules/distributed/AMRDefaultRuleProcessor.java	230
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/rules/distributed/AMRLearnerProcessor.java	168
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/rules/distributed/AMRRuleSetProcessor.java	244
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/rules/distributed/AMRulesAggregatorProcessor.java	372
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/rules/distributed/AMRulesStatisticsProcessor.java	135
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/rules/distributed/AssignmentContentEvent.java	32
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/rules/distributed/PredicateContentEvent.java	38
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/rules/distributed/RuleContentEvent.java	37
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/trees/ActiveLearningNode.java	141
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/trees/AttributeBatchContentEvent.java	83
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/trees/AttributeContentEvent.java	146
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/trees/AttributeSliceEvent.java	52
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/trees/BoostVHTActiveLearningNode.java	98
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/trees/ComputeContentEvent.java	84
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/trees/ControlContentEvent.java	30
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/trees/DeleteContentEvent.java	14
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/trees/FilterProcessor.java	109
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/trees/FoundNode.java	24
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/trees/InactiveLearningNode.java	17
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/trees/LearningNode.java	18
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/trees/LocalResultContentEvent.java	46
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/trees/LocalStatisticsProcessor.java	184
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/trees/ModelAggregatorProcessor.java	516
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/trees/Node.java	21
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/trees/SplitNode.java	51
samoa-api/src/main/java/org/apache/samoa/learners/classifiers/trees/VerticalHoeffdingTree.java	118
samoa-api/src/main/java/org/apache/samoa/learners/clusterers/ClusteringContentEvent.java	42
samoa-api/src/main/java/org/apache/samoa/learners/clusterers/ClustreamClustererAdapter.java	74
samoa-api/src/main/java/org/apache/samoa/learners/clusterers/LocalClustererAdapter.java	15
samoa-api/src/main/java/org/apache/samoa/learners/clusterers/LocalClustererProcessor.java	94
samoa-api/src/main/java/org/apache/samoa/learners/clusterers/SingleLearner.java	44
samoa-api/src/main/java/org/apache/samoa/learners/clusterers/simple/ClusteringDistributorProcessor.java	50
samoa-api/src/main/java/org/apache/samoa/learners/clusterers/simple/DistributedClusterer.java	57
samoa-api/src/main/java/org/apache/samoa/moa/AbstractMOAObject.java	28
samoa-api/src/main/java/org/apache/samoa/moa/MOAObject.java	7
samoa-api/src/main/java/org/apache/samoa/moa/classifiers/AbstractClassifier.java	221
samoa-api/src/main/java/org/apache/samoa/moa/classifiers/Classifier.java	11
samoa-api/src/main/java/org/apache/samoa/moa/classifiers/Regressor.java	3
samoa-api/src/main/java/org/apache/samoa/moa/classifiers/core/AttributeSplitSuggestion.java	31
samoa-api/src/main/java/org/apache/samoa/moa/classifiers/core/attributeclassobservers/AttributeClassObserver.java	13
samoa-api/src/main/java/org/apache/samoa/moa/classifiers/core/attributeclassobservers/BinaryTreeNumericAttributeClassObserver.java	124
samoa-api/src/main/java/org/apache/samoa/moa/classifiers/core/attributeclassobservers/BinaryTreeNumericAttributeClassObserverRegression.java	93
samoa-api/src/main/java/org/apache/samoa/moa/classifiers/core/attributeclassobservers/DiscreteAttributeClassObserver.java	3
samoa-api/src/main/java/org/apache/samoa/moa/classifiers/core/attributeclassobservers/FIMTDDNumericAttributeClassObserver.java	159
samoa-api/src/main/java/org/apache/samoa/moa/classifiers/core/attributeclassobservers/GaussianNumericAttributeClassObserver.java	131
samoa-api/src/main/java/org/apache/samoa/moa/classifiers/core/attributeclassobservers/GreenwaldKhannaNumericAttributeClassObserver.java	81
samoa-api/src/main/java/org/apache/samoa/moa/classifiers/core/attributeclassobservers/NominalAttributeClassObserver.java	129
samoa-api/src/main/java/org/apache/samoa/moa/classifiers/core/attributeclassobservers/NullAttributeClassObserver.java	39
samoa-api/src/main/java/org/apache/samoa/moa/classifiers/core/attributeclassobservers/NumericAttributeClassObserver.java	3
samoa-api/src/main/java/org/apache/samoa/moa/classifiers/core/attributeclassobservers/VFMLNumericAttributeClassObserver.java	152
samoa-api/src/main/java/org/apache/samoa/moa/classifiers/core/conditionaltests/InstanceConditionalBinaryTest.java	7
samoa-api/src/main/java/org/apache/samoa/moa/classifiers/core/conditionaltests/InstanceConditionalTest.java	14
samoa-api/src/main/java/org/apache/samoa/moa/classifiers/core/conditionaltests/NominalAttributeBinaryTest.java	36
samoa-api/src/main/java/org/apache/samoa/moa/classifiers/core/conditionaltests/NominalAttributeMultiwayTest.java	33
samoa-api/src/main/java/org/apache/samoa/moa/classifiers/core/conditionaltests/NumericAttributeBinaryTest.java	52
samoa-api/src/main/java/org/apache/samoa/moa/classifiers/core/driftdetection/ADWIN.java	394
samoa-api/src/main/java/org/apache/samoa/moa/classifiers/core/driftdetection/ADWINChangeDetector.java	30
samoa-api/src/main/java/org/apache/samoa/moa/classifiers/core/driftdetection/AbstractChangeDetector.java	37
samoa-api/src/main/java/org/apache/samoa/moa/classifiers/core/driftdetection/ChangeDetector.java	15
samoa-api/src/main/java/org/apache/samoa/moa/classifiers/core/driftdetection/CusumDM.java	59
samoa-api/src/main/java/org/apache/samoa/moa/classifiers/core/driftdetection/DDM.java	62
samoa-api/src/main/java/org/apache/samoa/moa/classifiers/core/driftdetection/EDDM.java	74
samoa-api/src/main/java/org/apache/samoa/moa/classifiers/core/driftdetection/EWMAChartDM.java	64
samoa-api/src/main/java/org/apache/samoa/moa/classifiers/core/driftdetection/GeometricMovingAverageDM.java	59
samoa-api/src/main/java/org/apache/samoa/moa/classifiers/core/driftdetection/PageHinkleyDM.java	63
samoa-api/src/main/java/org/apache/samoa/moa/classifiers/core/splitcriteria/GiniSplitCriterion.java	46
samoa-api/src/main/java/org/apache/samoa/moa/classifiers/core/splitcriteria/InfoGainSplitCriterion.java	76
samoa-api/src/main/java/org/apache/samoa/moa/classifiers/core/splitcriteria/InfoGainSplitCriterionMultilabel.java	21
samoa-api/src/main/java/org/apache/samoa/moa/classifiers/core/splitcriteria/SDRSplitCriterion.java	10
samoa-api/src/main/java/org/apache/samoa/moa/classifiers/core/splitcriteria/SplitCriterion.java	7
samoa-api/src/main/java/org/apache/samoa/moa/classifiers/core/splitcriteria/VarianceReductionSplitCriterion.java	46
samoa-api/src/main/java/org/apache/samoa/moa/classifiers/functions/DecisionStump.java	102
samoa-api/src/main/java/org/apache/samoa/moa/classifiers/functions/MajorityClass.java	47
samoa-api/src/main/java/org/apache/samoa/moa/classifiers/rules/core/Predicate.java	5
samoa-api/src/main/java/org/apache/samoa/moa/classifiers/rules/core/attributeclassobservers/FIMTDDNumericAttributeClassLimitObserver.java	68
samoa-api/src/main/java/org/apache/samoa/moa/classifiers/rules/core/conditionaltests/NumericAttributeBinaryRulePredicate.java	106
samoa-api/src/main/java/org/apache/samoa/moa/classifiers/rules/core/splitcriteria/SDRSplitCriterionAMRules.java	47
samoa-api/src/main/java/org/apache/samoa/moa/classifiers/rules/core/voting/AbstractErrorWeightedVote.java	62
samoa-api/src/main/java/org/apache/samoa/moa/classifiers/rules/core/voting/ErrorWeightedVote.java	11
samoa-api/src/main/java/org/apache/samoa/moa/classifiers/rules/core/voting/InverseErrorWeightedVote.java	53
samoa-api/src/main/java/org/apache/samoa/moa/classifiers/rules/core/voting/UniformWeightedVote.java	34
samoa-api/src/main/java/org/apache/samoa/moa/classifiers/rules/driftdetection/PageHinkleyFading.java	45
samoa-api/src/main/java/org/apache/samoa/moa/classifiers/rules/driftdetection/PageHinkleyTest.java	56
samoa-api/src/main/java/org/apache/samoa/moa/cluster/CFCluster.java	71
samoa-api/src/main/java/org/apache/samoa/moa/cluster/Cluster.java	90
samoa-api/src/main/java/org/apache/samoa/moa/cluster/Clustering.java	188
samoa-api/src/main/java/org/apache/samoa/moa/cluster/Miniball.java	47
samoa-api/src/main/java/org/apache/samoa/moa/cluster/SphereCluster.java	231
samoa-api/src/main/java/org/apache/samoa/moa/clusterers/AbstractClusterer.java	215
samoa-api/src/main/java/org/apache/samoa/moa/clusterers/ClusterGenerator.java	242
samoa-api/src/main/java/org/apache/samoa/moa/clusterers/Clusterer.java	25
samoa-api/src/main/java/org/apache/samoa/moa/clusterers/KMeans.java	125
samoa-api/src/main/java/org/apache/samoa/moa/clusterers/clustream/Clustream.java	231
samoa-api/src/main/java/org/apache/samoa/moa/clusterers/clustream/ClustreamKernel.java	176
samoa-api/src/main/java/org/apache/samoa/moa/clusterers/clustream/WithKmeans.java	311
samoa-api/src/main/java/org/apache/samoa/moa/core/AutoClassDiscovery.java	134
samoa-api/src/main/java/org/apache/samoa/moa/core/AutoExpandVector.java	87
samoa-api/src/main/java/org/apache/samoa/moa/core/DataPoint.java	92
samoa-api/src/main/java/org/apache/samoa/moa/core/DoubleVector.java	140
samoa-api/src/main/java/org/apache/samoa/moa/core/Example.java	6
samoa-api/src/main/java/org/apache/samoa/moa/core/FastVector.java	13
samoa-api/src/main/java/org/apache/samoa/moa/core/GaussianEstimator.java	76
samoa-api/src/main/java/org/apache/samoa/moa/core/GreenwaldKhannaQuantileSummary.java	208
samoa-api/src/main/java/org/apache/samoa/moa/core/InputStreamProgressMonitor.java	64
samoa-api/src/main/java/org/apache/samoa/moa/core/InstanceExample.java	22
samoa-api/src/main/java/org/apache/samoa/moa/core/Measurement.java	80
samoa-api/src/main/java/org/apache/samoa/moa/core/MiscUtils.java	53
samoa-api/src/main/java/org/apache/samoa/moa/core/ObjectRepository.java	4
samoa-api/src/main/java/org/apache/samoa/moa/core/SerializeUtils.java	74
samoa-api/src/main/java/org/apache/samoa/moa/core/Statistics.java	718
samoa-api/src/main/java/org/apache/samoa/moa/core/StringUtils.java	60
samoa-api/src/main/java/org/apache/samoa/moa/core/Utils.java	1432
samoa-api/src/main/java/org/apache/samoa/moa/core/Vote.java	50
samoa-api/src/main/java/org/apache/samoa/moa/evaluation/LearningCurve.java	134
samoa-api/src/main/java/org/apache/samoa/moa/evaluation/LearningEvaluation.java	29
samoa-api/src/main/java/org/apache/samoa/moa/evaluation/LearningPerformanceEvaluator.java	9
samoa-api/src/main/java/org/apache/samoa/moa/evaluation/MeasureCollection.java	191
samoa-api/src/main/java/org/apache/samoa/moa/evaluation/MembershipMatrix.java	102
samoa-api/src/main/java/org/apache/samoa/moa/learners/Learner.java	20
samoa-api/src/main/java/org/apache/samoa/moa/options/AbstractClassOption.java	114
samoa-api/src/main/java/org/apache/samoa/moa/options/AbstractOptionHandler.java	53
samoa-api/src/main/java/org/apache/samoa/moa/options/ClassOption.java	134
samoa-api/src/main/java/org/apache/samoa/moa/options/OptionHandler.java	15
samoa-api/src/main/java/org/apache/samoa/moa/options/OptionsHandler.java	55
samoa-api/src/main/java/org/apache/samoa/moa/tasks/NullMonitor.java	59
samoa-api/src/main/java/org/apache/samoa/moa/tasks/ResultPreviewListener.java	4
samoa-api/src/main/java/org/apache/samoa/moa/tasks/Task.java	8
samoa-api/src/main/java/org/apache/samoa/moa/tasks/TaskMonitor.java	20
samoa-api/src/main/java/org/apache/samoa/streams/ArffFileStream.java	80
samoa-api/src/main/java/org/apache/samoa/streams/AvroFileStream.java	93
samoa-api/src/main/java/org/apache/samoa/streams/ClusteringEntranceProcessor.java	114
samoa-api/src/main/java/org/apache/samoa/streams/ExampleStream.java	12
samoa-api/src/main/java/org/apache/samoa/streams/FileStream.java	115
samoa-api/src/main/java/org/apache/samoa/streams/InstanceStream.java	5
samoa-api/src/main/java/org/apache/samoa/streams/PrequentialSourceProcessor.java	135
samoa-api/src/main/java/org/apache/samoa/streams/StreamSource.java	23
samoa-api/src/main/java/org/apache/samoa/streams/StreamSourceProcessor.java	69
samoa-api/src/main/java/org/apache/samoa/streams/TextGenerator.java	146
samoa-api/src/main/java/org/apache/samoa/streams/clustering/ClusterEvent.java	22
samoa-api/src/main/java/org/apache/samoa/streams/clustering/ClusterEventListener.java	5
samoa-api/src/main/java/org/apache/samoa/streams/clustering/ClusteringStream.java	24
samoa-api/src/main/java/org/apache/samoa/streams/clustering/RandomRBFGeneratorEvents.java	686
samoa-api/src/main/java/org/apache/samoa/streams/fs/FileStreamSource.java	10
samoa-api/src/main/java/org/apache/samoa/streams/fs/HDFSFileStreamSource.java	105
samoa-api/src/main/java/org/apache/samoa/streams/fs/LocalFileStreamSource.java	86
samoa-api/src/main/java/org/apache/samoa/streams/generators/HyperplaneGenerator.java	126
samoa-api/src/main/java/org/apache/samoa/streams/generators/RandomTreeGenerator.java	204
samoa-api/src/main/java/org/apache/samoa/streams/kafka/KafkaConsumerThread.java	97
samoa-api/src/main/java/org/apache/samoa/streams/kafka/KafkaDeserializer.java	5
samoa-api/src/main/java/org/apache/samoa/streams/kafka/KafkaDestinationProcessor.java	45
samoa-api/src/main/java/org/apache/samoa/streams/kafka/KafkaEntranceProcessor.java	64
samoa-api/src/main/java/org/apache/samoa/streams/kafka/KafkaSerializer.java	5
samoa-api/src/main/java/org/apache/samoa/streams/kafka/KafkaUtils.java	61
samoa-api/src/main/java/org/apache/samoa/tasks/ClusteringEvaluation.java	116
samoa-api/src/main/java/org/apache/samoa/tasks/KafkaTask.java	101
samoa-api/src/main/java/org/apache/samoa/tasks/PrequentialCVEvaluation.java	100
samoa-api/src/main/java/org/apache/samoa/tasks/PrequentialEvaluation.java	127
samoa-api/src/main/java/org/apache/samoa/tasks/Task.java	8
samoa-api/src/main/java/org/apache/samoa/tasks/WriteArffFile.java	91
samoa-api/src/main/java/org/apache/samoa/topology/AbstractEntranceProcessingItem.java	35
samoa-api/src/main/java/org/apache/samoa/topology/AbstractProcessingItem.java	47
samoa-api/src/main/java/org/apache/samoa/topology/AbstractStream.java	33
samoa-api/src/main/java/org/apache/samoa/topology/AbstractTopology.java	43
samoa-api/src/main/java/org/apache/samoa/topology/ComponentFactory.java	10
samoa-api/src/main/java/org/apache/samoa/topology/EntranceProcessingItem.java	7
samoa-api/src/main/java/org/apache/samoa/topology/IProcessingItem.java	5
samoa-api/src/main/java/org/apache/samoa/topology/ISubmitter.java	6
samoa-api/src/main/java/org/apache/samoa/topology/LocalEntranceProcessingItem.java	33
samoa-api/src/main/java/org/apache/samoa/topology/ProcessingItem.java	7
samoa-api/src/main/java/org/apache/samoa/topology/Stream.java	7
samoa-api/src/main/java/org/apache/samoa/topology/Topology.java	9
samoa-api/src/main/java/org/apache/samoa/topology/TopologyBuilder.java	118
samoa-api/src/main/java/org/apache/samoa/utils/PartitioningScheme.java	4
samoa-api/src/main/java/org/apache/samoa/utils/StreamDestination.java	21
samoa-api/src/main/resources/kafka.avsc	105