public class StreamingClusteringEvaluationProcessor extends EvaluationProcessor
Modifier and Type | Class and Description |
---|---|
static class |
StreamingClusteringEvaluationProcessor.Builder
Builder Class
|
Modifier and Type | Field and Description |
---|---|
int |
numberOfClusters |
Queue<org.apache.samoa.moa.cluster.Clustering> |
samoaClusters |
experimentStart, firstDump, immediateResultStream, learningCurve, processId, sampleStart, totalCount
Modifier and Type | Method and Description |
---|---|
org.apache.samoa.core.Processor |
newProcessor(org.apache.samoa.core.Processor p) |
void |
onCreate(int id) |
boolean |
process(org.apache.samoa.core.ContentEvent event) |
void |
setNumberOfClusters(int numberOfClusters) |
void |
setSamoaClusters(Queue<org.apache.samoa.moa.cluster.Clustering> samoaClusters) |
toString
public Queue<org.apache.samoa.moa.cluster.Clustering> samoaClusters
public int numberOfClusters
public boolean process(org.apache.samoa.core.ContentEvent event)
process
in interface org.apache.samoa.core.Processor
process
in class EvaluationProcessor
public void onCreate(int id)
onCreate
in interface org.apache.samoa.core.Processor
onCreate
in class EvaluationProcessor
public org.apache.samoa.core.Processor newProcessor(org.apache.samoa.core.Processor p)
newProcessor
in interface org.apache.samoa.core.Processor
newProcessor
in class EvaluationProcessor
public void setSamoaClusters(Queue<org.apache.samoa.moa.cluster.Clustering> samoaClusters)
public void setNumberOfClusters(int numberOfClusters)
Copyright © 2017 WSO2. All rights reserved.