A C G I O P R S

A

ATTRIBUTE_CURRENT_PRIORITY - Static variable in class org.wso2.extension.siddhi.execution.priority.PriorityStreamProcessor

Second attribute name injected by PriorityStreamProcessor into the output stream event.

ATTRIBUTE_PRIORITY_KEY - Static variable in class org.wso2.extension.siddhi.execution.priority.PriorityStreamProcessor

First attribute name injected by PriorityStreamProcessor into the output stream event.

C

currentState() - Method in class org.wso2.extension.siddhi.execution.priority.PriorityStreamProcessor

G

getScheduler() - Method in class org.wso2.extension.siddhi.execution.priority.PriorityStreamProcessor

I

init(AbstractDefinition, ExpressionExecutor[], ConfigReader, SiddhiAppContext) - Method in class org.wso2.extension.siddhi.execution.priority.PriorityStreamProcessor

Initialize the PriorityStreamProcessor.

O

org.wso2.extension.siddhi.execution.priority - package org.wso2.extension.siddhi.execution.priority

P

PriorityStreamProcessor - Class in org.wso2.extension.siddhi.execution.priority

PriorityStreamProcessor keeps track of the priority of events in a stream.

PriorityStreamProcessor() - Constructor for class org.wso2.extension.siddhi.execution.priority.PriorityStreamProcessor

process(ComplexEventChunk<StreamEvent>, Processor, StreamEventCloner, ComplexEventPopulater) - Method in class org.wso2.extension.siddhi.execution.priority.PriorityStreamProcessor

Process events received by PriorityStreamProcessor.

R

restoreState(Map<String, Object>) - Method in class org.wso2.extension.siddhi.execution.priority.PriorityStreamProcessor

S

setScheduler(Scheduler) - Method in class org.wso2.extension.siddhi.execution.priority.PriorityStreamProcessor

start() - Method in class org.wso2.extension.siddhi.execution.priority.PriorityStreamProcessor

stop() - Method in class org.wso2.extension.siddhi.execution.priority.PriorityStreamProcessor

A C G I O P R S