org.wso2.extension.siddhi.execution.ml.samoa.utils.regression

Class StreamingRegressionEvaluationProcessor

java.lang.Object

org.wso2.extension.siddhi.execution.ml.samoa.utils.EvaluationProcessor

org.wso2.extension.siddhi.execution.ml.samoa.utils.regression.StreamingRegressionEvaluationProcessor

All Implemented Interfaces:

com.github.javacliparser.Configurable, Serializable, org.apache.samoa.core.Processor

public class StreamingRegressionEvaluationProcessor
extends EvaluationProcessor

Streaming Regression Evaluation Processor

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	StreamingRegressionEvaluationProcessor.Builder Builder Class

Field Summary

Fields

Modifier and Type	Field and Description
Queue<Vector>	samoaPredictions

Fields inherited from class org.wso2.extension.siddhi.execution.ml.samoa.utils.EvaluationProcessor

experimentStart, learningCurve, processId, sampleStart, totalCount

Constructor Summary

Constructors

Constructor and Description
StreamingRegressionEvaluationProcessor(StreamingRegressionEvaluationProcessor.Builder builder)

Method Summary

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	setSamoaPredictions(Queue<Vector> samoaPrediction)

Methods inherited from class org.wso2.extension.siddhi.execution.ml.samoa.utils.EvaluationProcessor

toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

samoaPredictions

public Queue<Vector> samoaPredictions

Constructor Detail

StreamingRegressionEvaluationProcessor

public StreamingRegressionEvaluationProcessor(StreamingRegressionEvaluationProcessor.Builder builder)

Method Detail

process

public boolean process(org.apache.samoa.core.ContentEvent event)

Specified by:

process in interface org.apache.samoa.core.Processor

Specified by:

process in class EvaluationProcessor

onCreate

public void onCreate(int id)

Specified by:

onCreate in interface org.apache.samoa.core.Processor

Specified by:

onCreate in class EvaluationProcessor

newProcessor

public org.apache.samoa.core.Processor newProcessor(org.apache.samoa.core.Processor p)

Specified by:

newProcessor in interface org.apache.samoa.core.Processor

Specified by:

newProcessor in class EvaluationProcessor

setSamoaPredictions

public void setSamoaPredictions(Queue<Vector> samoaPrediction)