org.wso2.extension.siddhi.execution.timeseries

Class LinearRegressionOutlierStreamProcessor

java.lang.Object

org.wso2.siddhi.core.query.processor.stream.AbstractStreamProcessor

org.wso2.siddhi.core.query.processor.stream.StreamProcessor

org.wso2.extension.siddhi.execution.timeseries.LinearRegressionOutlierStreamProcessor

All Implemented Interfaces:

org.wso2.siddhi.core.query.processor.Processor, org.wso2.siddhi.core.util.extension.holder.EternalReferencedHolder, org.wso2.siddhi.core.util.snapshot.Snapshotable

public class LinearRegressionOutlierStreamProcessor
extends org.wso2.siddhi.core.query.processor.stream.StreamProcessor

The outlier function takes in a dependent event stream (Y), an independent event stream (X) and a user specified range for outliers, and returns whether the current event is an outlier, based on the regression equation that fits historical data.

Field Summary

Fields inherited from class org.wso2.siddhi.core.query.processor.stream.StreamProcessor

outputExpectsExpiredEvents

Fields inherited from class org.wso2.siddhi.core.query.processor.stream.AbstractStreamProcessor

additionalAttributes, attributeExpressionExecutors, attributeExpressionLength, complexEventPopulater, elementId, inputDefinition, nextProcessor, queryName, siddhiAppContext, streamEventCloner, streamEventClonerHolder

Constructor Summary

Constructors

Constructor and Description
LinearRegressionOutlierStreamProcessor()

Method Summary

Modifier and Type	Method and Description
Map<String,Object>	currentState()
protected List<org.wso2.siddhi.query.api.definition.Attribute>	init(org.wso2.siddhi.query.api.definition.AbstractDefinition abstractDefinition, org.wso2.siddhi.core.executor.ExpressionExecutor[] expressionExecutors, org.wso2.siddhi.core.util.config.ConfigReader configReader, org.wso2.siddhi.core.config.SiddhiAppContext siddhiAppContext)
protected void	process(org.wso2.siddhi.core.event.ComplexEventChunk<org.wso2.siddhi.core.event.stream.StreamEvent> streamEventChunk, org.wso2.siddhi.core.query.processor.Processor nextProcessor, org.wso2.siddhi.core.event.stream.StreamEventCloner streamEventCloner, org.wso2.siddhi.core.event.stream.populater.ComplexEventPopulater complexEventPopulater)
void	restoreState(Map<String,Object> state)
void	start()
void	stop()

Methods inherited from class org.wso2.siddhi.core.query.processor.stream.StreamProcessor

init, processEventChunk

Methods inherited from class org.wso2.siddhi.core.query.processor.stream.AbstractStreamProcessor

cloneProcessor, constructStreamEventPopulater, getElementId, getNextProcessor, initProcessor, process, setNextProcessor, setStreamEventCloner, setToLast

Methods inherited from class java.lang.Object

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

Constructor Detail

LinearRegressionOutlierStreamProcessor

public LinearRegressionOutlierStreamProcessor()

Method Detail

process

protected void process(org.wso2.siddhi.core.event.ComplexEventChunk<org.wso2.siddhi.core.event.stream.StreamEvent> streamEventChunk,
                       org.wso2.siddhi.core.query.processor.Processor nextProcessor,
                       org.wso2.siddhi.core.event.stream.StreamEventCloner streamEventCloner,
                       org.wso2.siddhi.core.event.stream.populater.ComplexEventPopulater complexEventPopulater)

Specified by:

process in class org.wso2.siddhi.core.query.processor.stream.StreamProcessor

init

protected List<org.wso2.siddhi.query.api.definition.Attribute> init(org.wso2.siddhi.query.api.definition.AbstractDefinition abstractDefinition,
                                                                    org.wso2.siddhi.core.executor.ExpressionExecutor[] expressionExecutors,
                                                                    org.wso2.siddhi.core.util.config.ConfigReader configReader,
                                                                    org.wso2.siddhi.core.config.SiddhiAppContext siddhiAppContext)

Specified by:

init in class org.wso2.siddhi.core.query.processor.stream.StreamProcessor

start

public void start()

stop

public void stop()

currentState

public Map<String,Object> currentState()

restoreState

public void restoreState(Map<String,Object> state)