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

Class StreamingRegressionTask

java.lang.Object

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

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

All Implemented Interfaces:

com.github.javacliparser.Configurable, Serializable, org.apache.samoa.tasks.Task

public class StreamingRegressionTask
extends ProcessTask

Streaming Regression Task

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
Queue<Vector>	samoaPredictions

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

batchDelayOption, builder, cepEvents, dumpFileOption, evaluationNameOption, evaluatorOption, inputStream, instanceLimitOption, learner, learnerOption, sampleFrequencyOption, samplingThresholdOption, source, sourceDelayOption, sourcePiOutputStream, streamTrainOption, topology

Constructor Summary

Constructors

Constructor and Description
StreamingRegressionTask()

Method Summary

Modifier and Type	Method and Description
void	init()
void	setSamoaData(Queue<Vector> data)

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

getDefaultPerformanceEvaluatorForLearner, getTopology, isLearnerAndEvaluatorCompatible, setCepEvents, setFactory

Methods inherited from class java.lang.Object

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

Field Detail

samoaPredictions

public Queue<Vector> samoaPredictions

Constructor Detail

StreamingRegressionTask

public StreamingRegressionTask()

Method Detail

init

public void init()

Specified by:

init in interface org.apache.samoa.tasks.Task

Specified by:

init in class ProcessTask

setSamoaData

public void setSamoaData(Queue<Vector> data)