C D E F G I N O P R S U 

C

currentState() - Method in class org.wso2.siddhi.extension.geo.geoeventfuser.EventFusionProcessor
 
currentState() - Method in class org.wso2.siddhi.extension.geo.geoeventfuser.ExecutionPlanSubscriber
Used to collect the serializable state of the processing element, that need to be persisted for the reconstructing the element to the same state on a different point of time

D

downCount() - Static method in class org.wso2.siddhi.extension.geo.geoeventfuser.ExecutionPlansCount
 

E

EventFusionProcessor - Class in org.wso2.siddhi.extension.geo.geoeventfuser
 
EventFusionProcessor() - Constructor for class org.wso2.siddhi.extension.geo.geoeventfuser.EventFusionProcessor
 
ExecutionPlansCount - Class in org.wso2.siddhi.extension.geo.geoeventfuser
 
ExecutionPlansCount() - Constructor for class org.wso2.siddhi.extension.geo.geoeventfuser.ExecutionPlansCount
 
ExecutionPlanSubscriber - Class in org.wso2.siddhi.extension.geo.geoeventfuser
 
ExecutionPlanSubscriber() - Constructor for class org.wso2.siddhi.extension.geo.geoeventfuser.ExecutionPlanSubscriber
 

F

fuseEvent(StreamEvent) - Method in class org.wso2.siddhi.extension.geo.geoeventfuser.EventFusionProcessor
Fuse given StreamEvent.

G

getDeployedExecutionPlansCount() - Method in class org.wso2.siddhi.extension.geo.geoeventfuser.EventFusionProcessor
Get number of deployed execution plans.
getNumberOfExecutionPlans() - Static method in class org.wso2.siddhi.extension.geo.geoeventfuser.ExecutionPlansCount
 

I

init(ExpressionExecutor[], ExecutionPlanContext) - Method in class org.wso2.siddhi.extension.geo.geoeventfuser.EventFusionProcessor
Method called when initialising the extension.
init(AbstractDefinition, ExpressionExecutor[], ExecutionPlanContext) - Method in class org.wso2.siddhi.extension.geo.geoeventfuser.ExecutionPlanSubscriber
The init method of the StreamProcessor, this method will be called before other methods

N

numberOfExecutionPlans - Static variable in class org.wso2.siddhi.extension.geo.geoeventfuser.ExecutionPlansCount
 

O

org.wso2.siddhi.extension.geo.geoeventfuser - package org.wso2.siddhi.extension.geo.geoeventfuser
 

P

process(ComplexEventChunk<StreamEvent>, Processor, StreamEventCloner) - Method in class org.wso2.siddhi.extension.geo.geoeventfuser.EventFusionProcessor
This method called when processing an event list.
process(Object[]) - Method in class org.wso2.siddhi.extension.geo.geoeventfuser.ExecutionPlanSubscriber
The process method of the StreamFunction, used when more then one function parameters are provided
process(Object) - Method in class org.wso2.siddhi.extension.geo.geoeventfuser.ExecutionPlanSubscriber
The process method of the StreamFunction, used when zero or one function parameter is provided

R

restoreState(Object[]) - Method in class org.wso2.siddhi.extension.geo.geoeventfuser.EventFusionProcessor
 
restoreState(Object[]) - Method in class org.wso2.siddhi.extension.geo.geoeventfuser.ExecutionPlanSubscriber
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.

S

setNumberOfExecutionPlans(Integer) - Static method in class org.wso2.siddhi.extension.geo.geoeventfuser.ExecutionPlansCount
 
start() - Method in class org.wso2.siddhi.extension.geo.geoeventfuser.EventFusionProcessor
 
start() - Method in class org.wso2.siddhi.extension.geo.geoeventfuser.ExecutionPlanSubscriber
This will be called only once and this can be used to acquire required resources for the processing element.
stop() - Method in class org.wso2.siddhi.extension.geo.geoeventfuser.EventFusionProcessor
 
stop() - Method in class org.wso2.siddhi.extension.geo.geoeventfuser.ExecutionPlanSubscriber
This will be called only once and this can be used to release the acquired resources for processing.

U

upCount() - Static method in class org.wso2.siddhi.extension.geo.geoeventfuser.ExecutionPlansCount
 
C D E F G I N O P R S U 

Copyright © 2016 WSO2 Inc. All rights reserved.