io.cellery.observability.model.generator

Class TraceGroupWindowProcessor

java.lang.Object

org.wso2.siddhi.core.query.processor.stream.AbstractStreamProcessor

org.wso2.siddhi.core.query.processor.stream.StreamProcessor

io.cellery.observability.model.generator.TraceGroupWindowProcessor

All Implemented Interfaces:

org.wso2.siddhi.core.query.processor.Processor, org.wso2.siddhi.core.query.processor.SchedulingProcessor, org.wso2.siddhi.core.query.processor.stream.window.FindableProcessor, org.wso2.siddhi.core.util.extension.holder.EternalReferencedHolder, org.wso2.siddhi.core.util.snapshot.Snapshotable

public class TraceGroupWindowProcessor
extends org.wso2.siddhi.core.query.processor.stream.StreamProcessor
implements org.wso2.siddhi.core.query.processor.SchedulingProcessor, org.wso2.siddhi.core.query.processor.stream.window.FindableProcessor

Implementation of Stream Processor that groups the trace based on the trace key, and releases the trace together after the idle timeout.

Field Summary

Fields inherited from class org.wso2.siddhi.core.query.processor.stream.StreamProcessor

outputExpectsExpiredEvents

Fields inherited from class org.wso2.siddhi.core.query.processor.stream.AbstractStreamProcessor

additionalAttributes, attributeExpressionExecutors, attributeExpressionLength, complexEventPopulater, elementId, inputDefinition, nextProcessor, queryName, siddhiAppContext, streamEventCloner, streamEventClonerHolder

Constructor Summary

Constructors

Constructor and Description
TraceGroupWindowProcessor()

Method Summary

Modifier and Type	Method and Description
org.wso2.siddhi.core.util.collection.operator.CompiledCondition	compileCondition(org.wso2.siddhi.query.api.expression.Expression condition, org.wso2.siddhi.core.util.collection.operator.MatchingMetaInfoHolder matchingMetaInfoHolder, org.wso2.siddhi.core.config.SiddhiAppContext siddhiAppContext, List<org.wso2.siddhi.core.executor.VariableExpressionExecutor> variableExpressionExecutors, Map<String,org.wso2.siddhi.core.table.Table> tableMap, String queryName)
Map<String,Object>	currentState()
org.wso2.siddhi.core.event.stream.StreamEvent	find(org.wso2.siddhi.core.event.state.StateEvent matchingEvent, org.wso2.siddhi.core.util.collection.operator.CompiledCondition compiledCondition)
org.wso2.siddhi.core.util.Scheduler	getScheduler()
protected List<org.wso2.siddhi.query.api.definition.Attribute>	init(org.wso2.siddhi.query.api.definition.AbstractDefinition abstractDefinition, org.wso2.siddhi.core.executor.ExpressionExecutor[] expressionExecutors, org.wso2.siddhi.core.util.config.ConfigReader configReader, org.wso2.siddhi.core.config.SiddhiAppContext siddhiAppContext)
protected void	process(org.wso2.siddhi.core.event.ComplexEventChunk<org.wso2.siddhi.core.event.stream.StreamEvent> streamEventChunk, org.wso2.siddhi.core.query.processor.Processor processor, org.wso2.siddhi.core.event.stream.StreamEventCloner streamEventCloner, org.wso2.siddhi.core.event.stream.populater.ComplexEventPopulater complexEventPopulater)
void	restoreState(Map<String,Object> state)
void	setScheduler(org.wso2.siddhi.core.util.Scheduler scheduler)
void	start()
void	stop()

Methods inherited from class org.wso2.siddhi.core.query.processor.stream.StreamProcessor

init, processEventChunk

Methods inherited from class org.wso2.siddhi.core.query.processor.stream.AbstractStreamProcessor

cloneProcessor, constructStreamEventPopulater, getElementId, getNextProcessor, initProcessor, process, setNextProcessor, setStreamEventCloner, setToLast

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.wso2.siddhi.core.query.processor.Processor

cloneProcessor, getNextProcessor, process, setNextProcessor, setToLast

Constructor Detail

TraceGroupWindowProcessor

public TraceGroupWindowProcessor()

Method Detail

getScheduler

public org.wso2.siddhi.core.util.Scheduler getScheduler()

Specified by:

getScheduler in interface org.wso2.siddhi.core.query.processor.SchedulingProcessor

setScheduler

public void setScheduler(org.wso2.siddhi.core.util.Scheduler scheduler)

Specified by:

setScheduler in interface org.wso2.siddhi.core.query.processor.SchedulingProcessor

init

protected List<org.wso2.siddhi.query.api.definition.Attribute> init(org.wso2.siddhi.query.api.definition.AbstractDefinition abstractDefinition,
                                                                    org.wso2.siddhi.core.executor.ExpressionExecutor[] expressionExecutors,
                                                                    org.wso2.siddhi.core.util.config.ConfigReader configReader,
                                                                    org.wso2.siddhi.core.config.SiddhiAppContext siddhiAppContext)

Specified by:

init in class org.wso2.siddhi.core.query.processor.stream.StreamProcessor

process

protected void process(org.wso2.siddhi.core.event.ComplexEventChunk<org.wso2.siddhi.core.event.stream.StreamEvent> streamEventChunk,
                       org.wso2.siddhi.core.query.processor.Processor processor,
                       org.wso2.siddhi.core.event.stream.StreamEventCloner streamEventCloner,
                       org.wso2.siddhi.core.event.stream.populater.ComplexEventPopulater complexEventPopulater)

Specified by:

process in class org.wso2.siddhi.core.query.processor.stream.StreamProcessor

start

public void start()

Specified by:

start in interface org.wso2.siddhi.core.util.extension.holder.EternalReferencedHolder

stop

public void stop()

Specified by:

stop in interface org.wso2.siddhi.core.util.extension.holder.EternalReferencedHolder

currentState

public Map<String,Object> currentState()

Specified by:

currentState in interface org.wso2.siddhi.core.util.snapshot.Snapshotable

restoreState

public void restoreState(Map<String,Object> state)

Specified by:

restoreState in interface org.wso2.siddhi.core.util.snapshot.Snapshotable

find

public org.wso2.siddhi.core.event.stream.StreamEvent find(org.wso2.siddhi.core.event.state.StateEvent matchingEvent,
                                                          org.wso2.siddhi.core.util.collection.operator.CompiledCondition compiledCondition)

Specified by:

find in interface org.wso2.siddhi.core.query.processor.stream.window.FindableProcessor

compileCondition

public org.wso2.siddhi.core.util.collection.operator.CompiledCondition compileCondition(org.wso2.siddhi.query.api.expression.Expression condition,
                                                                                        org.wso2.siddhi.core.util.collection.operator.MatchingMetaInfoHolder matchingMetaInfoHolder,
                                                                                        org.wso2.siddhi.core.config.SiddhiAppContext siddhiAppContext,
                                                                                        List<org.wso2.siddhi.core.executor.VariableExpressionExecutor> variableExpressionExecutors,
                                                                                        Map<String,org.wso2.siddhi.core.table.Table> tableMap,
                                                                                        String queryName)

Specified by:

compileCondition in interface org.wso2.siddhi.core.query.processor.stream.window.FindableProcessor