public class FuseEvents
extends org.wso2.siddhi.core.query.processor.stream.window.WindowProcessor
Constructor and Description |
---|
FuseEvents() |
Modifier and Type | Method and Description |
---|---|
Object[] |
currentState() |
org.wso2.siddhi.core.event.ComplexEventChunk |
eventsFuser(org.wso2.siddhi.core.event.stream.StreamEvent event) |
Integer |
getDeployedExecutionPlansCount() |
protected void |
init(org.wso2.siddhi.core.executor.ExpressionExecutor[] attributeExpressionExecutors,
org.wso2.siddhi.core.config.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) |
void |
restoreState(Object[] state) |
void |
start() |
void |
stop() |
init, processEventChunk
protected void init(org.wso2.siddhi.core.executor.ExpressionExecutor[] attributeExpressionExecutors, org.wso2.siddhi.core.config.ExecutionPlanContext executionPlanContext)
init
in class org.wso2.siddhi.core.query.processor.stream.window.WindowProcessor
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
public Integer getDeployedExecutionPlansCount()
public org.wso2.siddhi.core.event.ComplexEventChunk eventsFuser(org.wso2.siddhi.core.event.stream.StreamEvent event)
public void start()
public void stop()
public Object[] currentState()
public void restoreState(Object[] state)
Copyright © 2015 WSO2 Inc. All rights reserved.