public class EventFusionProcessor
extends org.wso2.siddhi.core.query.processor.stream.window.WindowProcessor
Constructor and Description |
---|
EventFusionProcessor() |
Modifier and Type | Method and Description |
---|---|
Object[] |
currentState() |
void |
fuseEvent(org.wso2.siddhi.core.event.stream.StreamEvent event)
Fuse given
StreamEvent . |
Integer |
getDeployedExecutionPlansCount()
Get number of deployed execution plans.
|
protected void |
init(org.wso2.siddhi.core.executor.ExpressionExecutor[] expressionExecutors,
org.wso2.siddhi.core.config.ExecutionPlanContext executionPlanContext)
Method called when initialising the extension.
|
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)
This method called when processing an event list.
|
void |
restoreState(Object[] state) |
void |
start() |
void |
stop() |
init, processEventChunk
protected void init(org.wso2.siddhi.core.executor.ExpressionExecutor[] expressionExecutors, org.wso2.siddhi.core.config.ExecutionPlanContext executionPlanContext)
init
in class org.wso2.siddhi.core.query.processor.stream.window.WindowProcessor
expressionExecutors
- Array of ExpressionExecutor
executionPlanContext
- ExecutionPlanContext
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)
process
in class org.wso2.siddhi.core.query.processor.stream.window.WindowProcessor
streamEventChunk
- ComplexEventChunk
nextProcessor
- Processor
streamEventCloner
- StreamEventCloner
public Integer getDeployedExecutionPlansCount()
public void fuseEvent(org.wso2.siddhi.core.event.stream.StreamEvent event)
StreamEvent
.
-Precedence of states when fusing-
goes low to high from LHS to RHS
OFFLINE < NORMAL < WARNING < ALERT
States will be in all caps to mimics
that states not get on the way.event
- StreamEvent
to fusepublic void start()
public void stop()
public Object[] currentState()
public void restoreState(Object[] state)
Copyright © 2016 WSO2 Inc. All rights reserved.