public class LengthTimeLinearRegressionOutlierStreamProcessor
extends org.wso2.siddhi.core.query.processor.stream.StreamProcessor
Constructor and Description |
---|
LengthTimeLinearRegressionOutlierStreamProcessor() |
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)
The init method of the LinearRegressionOutlierStreamProcessor.
|
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)
The main processing method that will be called upon event arrival.
|
void |
restoreState(Map<String,Object> state) |
void |
start()
This will be called only once and this can be used to acquire required resources for the
processing element.
|
void |
stop()
This will be called only once and this can be used to release the acquired resources
for processing.
|
init, processEventChunk
public LengthTimeLinearRegressionOutlierStreamProcessor()
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)
init
in class org.wso2.siddhi.core.query.processor.stream.StreamProcessor
abstractDefinition
- the incoming stream definitionexpressionExecutors
- the executors of each function parameterssiddhiAppContext
- the context of the execution planprotected 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)
process
in class org.wso2.siddhi.core.query.processor.stream.StreamProcessor
streamEventChunk
- the event chunk that need to be processednextProcessor
- the next processor to which the success events need to be passedstreamEventCloner
- helps to clone the incoming event for local storage or
modificationcomplexEventPopulater
- helps to populate the events with the resultant attributespublic void start()
public void stop()
Copyright © 2018 WSO2. All rights reserved.