public class BayesianRegressionStreamProcessorExtension
extends org.wso2.siddhi.core.query.processor.stream.StreamProcessor
BayesianRegressionUpdaterStreamProcessorExtension
.outputExpectsExpiredEvents
additionalAttributes, attributeExpressionExecutors, attributeExpressionLength, complexEventPopulater, elementId, inputDefinition, nextProcessor, queryName, siddhiAppContext, streamEventCloner, streamEventClonerHolder
Constructor and Description |
---|
BayesianRegressionStreamProcessorExtension() |
Modifier and Type | Method and Description |
---|---|
Map<String,Object> |
currentState()
Used to collect the serializable state of the processing element, that need to be.
|
protected List<org.wso2.siddhi.query.api.definition.Attribute> |
init(org.wso2.siddhi.query.api.definition.AbstractDefinition inputDefinition,
org.wso2.siddhi.core.executor.ExpressionExecutor[] attributeExpressionExecutors,
org.wso2.siddhi.core.util.config.ConfigReader configReader,
org.wso2.siddhi.core.config.SiddhiAppContext siddhiAppContext)
The initialization method for
BayesianRegressionStreamProcessorExtension ,
which will be called before other methods and validate
the all configuration and getting the initial values. |
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)
Used to restore serialized state of the processing element, for reconstructing
the element to the same state as if was on a previous point of time.
|
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 BayesianRegressionStreamProcessorExtension()
protected List<org.wso2.siddhi.query.api.definition.Attribute> init(org.wso2.siddhi.query.api.definition.AbstractDefinition inputDefinition, org.wso2.siddhi.core.executor.ExpressionExecutor[] attributeExpressionExecutors, org.wso2.siddhi.core.util.config.ConfigReader configReader, org.wso2.siddhi.core.config.SiddhiAppContext siddhiAppContext)
BayesianRegressionStreamProcessorExtension
,
which will be called before other methods and validate
the all configuration and getting the initial values.init
in class org.wso2.siddhi.core.query.processor.stream.StreamProcessor
attributeExpressionExecutors
- are the executors of each attributes in the FunctionconfigReader
- this hold the StreamProcessor
extensions configuration reader.siddhiAppContext
- Siddhi app runtime contextprotected 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
public void start()
public void stop()
public Map<String,Object> currentState()
public void restoreState(Map<String,Object> state)
state
- the stateful objects of the processing element as a map.
This is the same map that is created upon calling currentState() method.Copyright © 2019 WSO2. All rights reserved.