com.espertech.esper.metrics.instrumentation
Interface Instrumentation
- All Known Implementing Classes:
- InstrumentationDefault
public interface Instrumentation
Method Summary |
void |
aAggAccessEnterLeave(boolean enter,
int index,
AggregationState state)
|
void |
aAggNoAccessEnterLeave(boolean enter,
int index,
AggregationMethod aggregationMethod)
|
void |
aAggregationGroupedApplyEnterLeave(boolean enter)
|
void |
aAggregationUngroupedApplyEnterLeave(boolean enter)
|
void |
aContextPartitionAllocate()
|
void |
aContextPartitionDestroy()
|
void |
aContextScheduledEval()
|
void |
aEngineManagementStmtCompileStart(boolean success,
java.lang.String message)
|
void |
aEngineManagementStmtStop()
|
void |
aEvent()
|
void |
aEventCP()
|
void |
aExprAnd(java.lang.Boolean result)
|
void |
aExprArray(java.lang.Object result)
|
void |
aExprBetween(java.lang.Boolean result)
|
void |
aExprBitwise(java.lang.Object result)
|
void |
aExprBool(java.lang.Boolean result)
|
void |
aExprCase(java.lang.Object result)
|
void |
aExprCast(java.lang.Object result)
|
void |
aExprCoalesce(java.lang.Object value)
|
void |
aExprConcat(java.lang.String result)
|
void |
aExprContextProp(java.lang.Object result)
|
void |
aExprDeclared(java.lang.Object value)
|
void |
aExprDot(java.lang.Object result)
|
void |
aExprDotChain()
|
void |
aExprDotChainElement(ExpressionReturnType typeInfo,
java.lang.Object result)
|
void |
aExprEquals(java.lang.Boolean result)
|
void |
aExprEqualsAnyOrAll(java.lang.Boolean result)
|
void |
aExprIdent(java.lang.Object result)
|
void |
aExprIn(java.lang.Boolean result)
|
void |
aExprInstanceof(java.lang.Boolean result)
|
void |
aExprIs(boolean result)
|
void |
aExprLike(java.lang.Boolean result)
|
void |
aExprMath(java.lang.Object result)
|
void |
aExprMinMaxRow(java.lang.Object result)
|
void |
aExprNew(java.util.Map<java.lang.String,java.lang.Object> props)
|
void |
aExprNot(java.lang.Boolean result)
|
void |
aExprOr(java.lang.Boolean result)
|
void |
aExprPlugInSingleRow(java.lang.Object result)
|
void |
aExprPrev(java.lang.Object result)
|
void |
aExprPrior(java.lang.Object result)
|
void |
aExprPropExists(boolean exists)
|
void |
aExprRegexp(java.lang.Boolean result)
|
void |
aExprRelOp(java.lang.Boolean result)
|
void |
aExprRelOpAnyOrAll(java.lang.Boolean result)
|
void |
aExprStreamEventMethod(java.lang.Object result)
|
void |
aExprStreamUnd(java.lang.Object result)
|
void |
aExprStreamUndMethod(java.lang.Object result)
|
void |
aExprStreamUndSelectClause(EventBean event)
|
void |
aExprSubselect(java.lang.Object result)
|
void |
aExprTimePeriod(java.lang.Object result)
|
void |
aExprTypeof(java.lang.String typeName)
|
void |
aExprValue(java.lang.Object result)
|
void |
aExprVariable(java.lang.Object value)
|
void |
aFilter(java.util.Collection<FilterHandle> matches)
|
void |
aFilterActivationNamedWindowInsert()
|
void |
aFilterActivationOnTrigger()
|
void |
aFilterActivationStream()
|
void |
aFilterActivationSubselect()
|
void |
aFilterAdd()
|
void |
aFilterBoolean()
|
void |
aFilterBooleanExpr(boolean result)
|
void |
aFilterHandleSetIndexes()
|
void |
aFilterRemove()
|
void |
aFilterReverseIndex(java.lang.Boolean match)
|
void |
aHavingClauseJoin(java.lang.Boolean pass)
|
void |
aHavingClauseNonJoin(java.lang.Boolean pass)
|
void |
aHistoricalScheduledEval()
|
void |
aIndexAdd()
|
void |
aIndexAddRemove()
|
void |
aIndexJoinLookup(java.util.Set<EventBean> result,
java.lang.Object keys)
|
void |
aIndexRemove()
|
void |
aIndexSubordLookup(java.util.Collection<EventBean> events,
java.lang.Object keys)
|
void |
aJoinCompositionHistorical(java.util.Set<MultiKey<EventBean>> newResults,
java.util.Set<MultiKey<EventBean>> oldResults)
|
void |
aJoinCompositionQueryStrategy()
|
void |
aJoinCompositionStepUpdIndex()
|
void |
aJoinCompositionStreamToWin(java.util.Set<MultiKey<EventBean>> newResults)
|
void |
aJoinCompositionWinToWin(java.util.Set<MultiKey<EventBean>> newResults,
java.util.Set<MultiKey<EventBean>> oldResults)
|
void |
aJoinDispatch()
|
void |
aJoinExecFilter(java.util.Set<MultiKey<EventBean>> newEvents,
java.util.Set<MultiKey<EventBean>> oldEvents)
|
void |
aJoinExecProcess()
|
void |
aJoinExecStrategy(UniformPair<java.util.Set<MultiKey<EventBean>>> joinSet)
|
void |
aNamedWindowCPMulti()
|
void |
aNamedWindowCPSingle()
|
void |
aNamedWindowDispatch()
|
void |
aNamedWindowMergeWhenThenActionItem(boolean applies)
|
void |
aNamedWindowMergeWhenThenActions()
|
void |
aNamedWindowMergeWhenThenItem(boolean matched,
boolean actionsApplied)
|
void |
aNamedWindowMergeWhenThens(boolean matched)
|
void |
aNamedWindowOnAction()
|
void |
aNamedWindowTriggeredLookup(EventBean[] result)
|
void |
aNamedWindowUpdate(EventBean copy)
|
void |
aNamedWindowUpdateRHSExpr(java.lang.Object result)
|
void |
aOrderBy(java.lang.Object values)
|
void |
aOutputProcessNonBuffered()
|
void |
aOutputProcessNonBufferedJoin()
|
void |
aOutputProcessWCondition(boolean buffered)
|
void |
aOutputProcessWConditionJoin(boolean buffered)
|
void |
aOutputRateConditionOutputNow(boolean generate)
|
void |
aOutputRateConditionScheduledEval()
|
void |
aOutputRateConditionUpdate()
|
void |
aPatternAndEvaluateFalse()
|
void |
aPatternAndEvaluateTrue(boolean quitted)
|
void |
aPatternAndQuit()
|
void |
aPatternAndStart()
|
void |
aPatternEveryDistinctEvalFalse()
|
void |
aPatternEveryDistinctEvaluateTrue(java.util.Set<java.lang.Object> keysFromNodeNoExpire,
java.util.LinkedHashMap<java.lang.Object,java.lang.Long> keysFromNodeExpire,
java.lang.Object matchEventKey,
boolean haveSeenThis)
|
void |
aPatternEveryDistinctQuit()
|
void |
aPatternEveryDistinctStart()
|
void |
aPatternEveryEvalFalse()
|
void |
aPatternEveryEvaluateTrue()
|
void |
aPatternEveryQuit()
|
void |
aPatternEveryStart()
|
void |
aPatternFilterMatch(boolean quitted)
|
void |
aPatternFilterQuit()
|
void |
aPatternFilterStart()
|
void |
aPatternFollowedByEvalFalse()
|
void |
aPatternFollowedByEvaluateTrue(boolean quitted)
|
void |
aPatternFollowedByQuit()
|
void |
aPatternFollowedByStart()
|
void |
aPatternGuardEvaluateTrue(boolean quitted)
|
void |
aPatternGuardGuardQuit()
|
void |
aPatternGuardQuit()
|
void |
aPatternGuardScheduledEval()
|
void |
aPatternGuardStart()
|
void |
aPatternMatchUntilEvalFalse()
|
void |
aPatternMatchUntilEvaluateTrue(boolean quitted)
|
void |
aPatternMatchUntilQuit()
|
void |
aPatternMatchUntilStart()
|
void |
aPatternNotEvalFalse()
|
void |
aPatternNotEvaluateTrue(boolean quitted)
|
void |
aPatternNotQuit()
|
void |
aPatternNotStart()
|
void |
aPatternObserverEvaluateTrue()
|
void |
aPatternObserverQuit()
|
void |
aPatternObserverScheduledEval()
|
void |
aPatternObserverStart()
|
void |
aPatternOrEvalFalse()
|
void |
aPatternOrEvaluateTrue(boolean quitted)
|
void |
aPatternOrQuit()
|
void |
aPatternOrStart()
|
void |
aPatternRootEvalFalse()
|
void |
aPatternRootEvaluateTrue(boolean quitted)
|
void |
aPatternRootQuit()
|
void |
aPatternRootStart()
|
void |
aRegEx(RegexPartitionState partitionState,
java.util.List<RegexNFAStateEntry> endStates,
java.util.List<RegexNFAStateEntry> terminationStates)
|
void |
aRegExPartition(boolean exists,
RegexPartitionState state)
|
void |
aRegExScheduledEval()
|
void |
aRegExState(java.util.List<RegexNFAStateEntry> next,
java.util.LinkedHashMap<java.lang.String,Pair<java.lang.Integer,java.lang.Boolean>> variableStreams,
int[] multimatchStreamNumToVariable)
|
void |
aRegIntervalState(boolean scheduled)
|
void |
aRegIntervalValue(long result)
|
void |
aRegMeasure(EventBean outBean)
|
void |
aRegOut()
|
void |
aResultSetProcessComputeGroupKeys(boolean enter,
java.lang.Object groupKeysPerEvent)
|
void |
aResultSetProcessGroupedRowPerEvent(EventBean[] selectNewEvents,
EventBean[] selectOldEvents)
|
void |
aResultSetProcessGroupedRowPerGroup(EventBean[] selectNewEvents,
EventBean[] selectOldEvents)
|
void |
aResultSetProcessSimple(EventBean[] selectNewEvents,
EventBean[] selectOldEvents)
|
void |
aResultSetProcessUngroupedFullyAgg(EventBean[] selectNewEvents,
EventBean[] selectOldEvents)
|
void |
aResultSetProcessUngroupedNonfullyAgg(EventBean[] selectNewEvents,
EventBean[] selectOldEvents)
|
void |
aRouteBetweenStmt()
|
void |
aScheduleAdd()
|
void |
aScheduleEval(java.util.Collection<ScheduleHandle> handles)
|
void |
aScheduleRemove()
|
void |
aSelectClause(boolean newData,
EventBean event,
java.lang.Object[] subscriberParameters)
|
void |
aSplitStream(boolean all,
boolean handled)
|
void |
aSplitStreamRoute()
|
void |
aSplitStreamWhere(java.lang.Boolean pass)
|
void |
aStimulantEvent()
|
void |
aStimulantTime()
|
void |
aSubselectAggregation()
|
void |
aTime()
|
void |
aTimeCP()
|
void |
aUpdateIStream(EventBean finalEvent,
boolean haveCloned)
|
void |
aUpdateIStreamApply(EventBean updated,
boolean applied)
|
void |
aUpdateIStreamApplyAssignmentItem(java.lang.Object value)
|
void |
aUpdateIStreamApplyAssignments(java.lang.Object[] values)
|
void |
aUpdateIStreamApplyWhere(java.lang.Boolean result)
|
void |
aViewIndicate()
|
void |
aViewProcessIRStream()
|
void |
aViewScheduledEval()
|
void |
aWhereClauseFilter(EventBean[] filteredNewData,
EventBean[] filteredOldData)
|
void |
aWhereClauseFilterEval(java.lang.Boolean pass)
|
void |
aWhereClauseIR()
|
void |
qaEngineManagementStmtStarted(java.lang.String engineURI,
java.lang.String statementId,
java.lang.String statementName,
java.lang.String epl,
long engineTime)
|
void |
qaExprAggValue(ExprAggregateNodeBase exprAggregateNodeBase,
java.lang.Object value)
|
void |
qaExprConst(java.lang.Object result)
|
void |
qaExprIStream(ExprIStreamNode exprIStreamNode,
boolean newData)
|
void |
qaExprTimestamp(ExprTimestampNode exprTimestampNode,
long value)
|
void |
qaFilterHandleSetCallbacks(java.util.Set<FilterHandle> callbackSet)
|
void |
qAggAccessEnterLeave(boolean enter,
int index,
AggregationState state,
AggregationStateFactory accessAggSpec)
|
void |
qAggNoAccessEnterLeave(boolean enter,
int index,
AggregationMethod aggregationMethod,
AggregationMethodFactory aggregationMethodFactory)
|
void |
qAggregationGroupedApplyEnterLeave(boolean enter,
int numAggregators,
int numAccessStates,
java.lang.Object groupKey)
|
void |
qAggregationUngroupedApplyEnterLeave(boolean enter,
int numAggregators,
int numAccessStates)
|
void |
qaStatementResultExecute(UniformPair<EventBean[]> events,
java.lang.String statementId,
java.lang.String statementName,
int agentInstanceId,
long threadId)
|
void |
qContextPartitionAllocate(AgentInstanceContext agentInstanceContext)
|
void |
qContextPartitionDestroy(AgentInstanceContext agentInstanceContext)
|
void |
qContextScheduledEval(ContextDescriptor contextDescriptor)
|
void |
qEngineManagementStmtCompileStart(java.lang.String engineURI,
java.lang.String statementId,
java.lang.String statementName,
java.lang.String epl,
long engineTime)
|
void |
qEngineManagementStmtStop(EPStatementState targetState,
java.lang.String engineURI,
java.lang.String statementId,
java.lang.String statementName,
java.lang.String epl,
long engineTime)
|
void |
qEvent(EventBean eventBean,
java.lang.String engineURI,
boolean providedBySendEvent)
|
void |
qEventCP(EventBean theEvent,
EPStatementAgentInstanceHandle handle,
long engineTime)
|
void |
qExprAnd(ExprNode exprNode)
|
void |
qExprArray(ExprArrayNode exprArrayNode)
|
void |
qExprBetween(ExprBetweenNodeImpl exprBetweenNode)
|
void |
qExprBitwise(ExprNode exprNode,
BitWiseOpEnum bitWiseOpEnum)
|
void |
qExprBool(ExprNode exprNode,
EventBean[] eventsPerStream)
|
void |
qExprCase(ExprCaseNode exprCaseNode)
|
void |
qExprCast(ExprCastNode exprCastNode)
|
void |
qExprCoalesce(ExprCoalesceNode exprCoalesceNode)
|
void |
qExprConcat(ExprConcatNode exprConcatNode)
|
void |
qExprContextProp(ExprContextPropertyNode exprContextPropertyNode)
|
void |
qExprDeclared(ExpressionDeclItem parent)
|
void |
qExprDot(ExprDotNode exprDotNode)
|
void |
qExprDotChain(ExpressionReturnType targetTypeInfo,
java.lang.Object target,
ExprDotEval[] evalUnpacking)
|
void |
qExprDotChainElement(int num,
ExprDotEval methodEval)
|
void |
qExprEquals(ExprNode exprNode)
|
void |
qExprEqualsAnyOrAll(ExprEqualsAllAnyNode exprEqualsAllAnyNode)
|
void |
qExprIdent(java.lang.String fullUnresolvedName)
|
void |
qExprIn(ExprInNodeImpl exprInNode)
|
void |
qExprInstanceof(ExprInstanceofNode exprInstanceofNode)
|
void |
qExprIs(ExprEqualsNodeImpl exprNode)
|
void |
qExprLike(ExprNode exprNode)
|
void |
qExprMath(ExprMathNode exprMathNode,
java.lang.String op)
|
void |
qExprMinMaxRow(ExprMinMaxRowNode exprMinMaxRowNode)
|
void |
qExprNew(ExprNewNode exprNewNode)
|
void |
qExprNot(ExprNotNode exprNotNode)
|
void |
qExprOr(ExprOrNode exprOrNode)
|
void |
qExprPlugInSingleRow(java.lang.reflect.Method method)
|
void |
qExprPrev(ExprPreviousNode exprPreviousNode,
boolean newData)
|
void |
qExprPrior(ExprPriorNode exprPriorNode)
|
void |
qExprPropExists(ExprPropertyExistsNode exprPropertyExistsNode)
|
void |
qExprRegexp(ExprRegexpNode exprRegexpNode)
|
void |
qExprRelOp(ExprRelationalOpNodeImpl exprRelationalOpNode,
java.lang.String op)
|
void |
qExprRelOpAnyOrAll(ExprRelationalOpAllAnyNode exprRelationalOpAllAnyNode,
java.lang.String op)
|
void |
qExprStreamEventMethod(ExprDotNode exprDotNode)
|
void |
qExprStreamUnd(ExprStreamUnderlyingNodeImpl exprStreamUnderlyingNode)
|
void |
qExprStreamUndMethod(ExprDotNode exprDotEvalStreamMethod)
|
void |
qExprStreamUndSelectClause(ExprStreamUnderlyingNode undNode)
|
void |
qExprSubselect(ExprSubselectNode exprSubselectNode)
|
void |
qExprTimePeriod(ExprTimePeriodImpl exprTimePeriod)
|
void |
qExprTypeof()
|
void |
qExprValue(ExprNode exprNode,
EventBean[] eventsPerStream)
|
void |
qExprVariable(ExprVariableNodeImpl exprVariableNode)
|
void |
qFilter(EventBean theEvent)
|
void |
qFilterActivationNamedWindowInsert(java.lang.String namedWindowName)
|
void |
qFilterActivationOnTrigger(java.lang.String eventTypeName)
|
void |
qFilterActivationStream(java.lang.String eventTypeName,
int streamNumber)
|
void |
qFilterActivationSubselect(java.lang.String eventTypeName,
ExprSubselectNode subselectNode)
|
void |
qFilterAdd(FilterValueSet filterValueSet,
FilterHandle filterCallback)
|
void |
qFilterBoolean(FilterParamIndexBooleanExpr filterParamIndexBooleanExpr)
|
void |
qFilterBooleanExpr(int num,
java.util.Map.Entry<ExprNodeAdapterBase,EventEvaluator> evals)
|
void |
qFilterHandleSetIndexes(java.util.List<FilterParamIndexBase> indizes)
|
void |
qFilterRemove(FilterHandle filterCallback,
EventTypeIndexBuilderValueIndexesPair pair)
|
void |
qFilterReverseIndex(FilterParamIndexLookupableBase filterParamIndex,
java.lang.Object propertyValue)
|
void |
qHavingClauseJoin(EventBean[] eventsPerStream)
|
void |
qHavingClauseNonJoin(EventBean theEvent)
|
void |
qHistoricalScheduledEval()
|
void |
qIndexAdd(EventTable eventTable,
EventBean[] addEvents)
|
void |
qIndexAddRemove(EventTable eventTable,
EventBean[] newData,
EventBean[] oldData)
|
void |
qIndexJoinLookup(JoinExecTableLookupStrategy strategy,
EventTable index)
|
void |
qIndexRemove(EventTable eventTable,
EventBean[] removeEvents)
|
void |
qIndexSubordLookup(SubordTableLookupStrategy subordTableLookupStrategy,
EventTable optionalEventIndex,
int[] keyStreamNums)
|
void |
qJoinCompositionHistorical()
|
void |
qJoinCompositionQueryStrategy(boolean insert,
int streamNum,
EventBean[] events)
|
void |
qJoinCompositionStepUpdIndex(int stream,
EventBean[] added,
EventBean[] removed)
|
void |
qJoinCompositionStreamToWin()
|
void |
qJoinCompositionWinToWin()
|
void |
qJoinDispatch(EventBean[][] newDataPerStream,
EventBean[][] oldDataPerStream)
|
void |
qJoinExecFilter()
|
void |
qJoinExecProcess(UniformPair<java.util.Set<MultiKey<EventBean>>> joinSet)
|
void |
qJoinExexStrategy()
|
void |
qNamedWindowCPMulti(java.lang.String engineURI,
java.util.Map<NamedWindowConsumerView,NamedWindowDeltaData> deltaPerConsumer,
EPStatementAgentInstanceHandle handle,
long time)
|
void |
qNamedWindowCPSingle(java.lang.String engineURI,
java.util.List<NamedWindowConsumerView> value,
EventBean[] newData,
EventBean[] oldData,
EPStatementAgentInstanceHandle handle,
long time)
|
void |
qNamedWindowDispatch(java.lang.String engineURI)
|
void |
qNamedWindowMergeWhenThenActionItem(int count,
NamedWindowOnMergeAction action)
|
void |
qNamedWindowMergeWhenThenActions(java.util.List<NamedWindowOnMergeAction> size)
|
void |
qNamedWindowMergeWhenThenItem(boolean matched,
NamedWindowOnMergeMatch whenThen,
int count)
|
void |
qNamedWindowMergeWhenThens(boolean matched,
EventBean triggerEvent,
java.util.List<NamedWindowOnMergeMatch> matchesSpec)
|
void |
qNamedWindowOnAction(OnTriggerType triggerType,
EventBean[] triggerEvents,
EventBean[] matchingEvents)
|
void |
qNamedWindowTriggeredLookup(NamedWindowLookupStrategyType lookupStrategy)
|
void |
qNamedWindowUpdate(EventBean matchingEvent,
EventBean[] eventsPerStream,
int length)
|
void |
qNamedWindowUpdateRHSExpr(int index,
NamedWindowUpdateItem updateItem)
|
void |
qOrderBy(EventBean[] evalEventsPerStream,
OrderByElement[] orderBy)
|
void |
qOutputProcessNonBuffered(EventBean[] newData,
EventBean[] oldData)
|
void |
qOutputProcessNonBufferedJoin(java.util.Set<MultiKey<EventBean>> newEvents,
java.util.Set<MultiKey<EventBean>> oldEvents)
|
void |
qOutputProcessWCondition(EventBean[] newData,
EventBean[] oldData)
|
void |
qOutputProcessWConditionJoin(java.util.Set<MultiKey<EventBean>> newEvents,
java.util.Set<MultiKey<EventBean>> oldEvents)
|
void |
qOutputRateConditionOutputNow()
|
void |
qOutputRateConditionScheduledEval()
|
void |
qOutputRateConditionUpdate(int newDataLength,
int oldDataLength)
|
void |
qPatternAndEvaluateFalse(EvalAndNode evalAndNode)
|
void |
qPatternAndEvaluateTrue(EvalAndNode evalAndNode,
MatchedEventMap passUp)
|
void |
qPatternAndQuit(EvalAndNode evalAndNode)
|
void |
qPatternAndStart(EvalAndNode evalAndNode,
MatchedEventMap beginState)
|
void |
qPatternEveryDistinctEvalFalse(EvalEveryDistinctNode everyNode)
|
void |
qPatternEveryDistinctEvaluateTrue(EvalEveryDistinctNode everyDistinctNode,
MatchedEventMap matchEvent)
|
void |
qPatternEveryDistinctQuit(EvalEveryDistinctNode everyNode)
|
void |
qPatternEveryDistinctStart(EvalEveryDistinctNode everyNode,
MatchedEventMap beginState)
|
void |
qPatternEveryEvalFalse(EvalEveryNode evalEveryNode)
|
void |
qPatternEveryEvaluateTrue(EvalEveryNode evalEveryNode,
MatchedEventMap matchEvent)
|
void |
qPatternEveryQuit(EvalEveryNode evalEveryNode)
|
void |
qPatternEveryStart(EvalEveryNode evalEveryNode,
MatchedEventMap beginState)
|
void |
qPatternFilterMatch(EvalFilterNode filterNode,
EventBean theEvent)
|
void |
qPatternFilterQuit(EvalFilterNode evalFilterNode,
MatchedEventMap beginState)
|
void |
qPatternFilterStart(EvalFilterNode evalFilterNode,
MatchedEventMap beginState)
|
void |
qPatternFollowedByEvalFalse(EvalFollowedByNode evalFollowedByNode)
|
void |
qPatternFollowedByEvaluateTrue(EvalFollowedByNode evalFollowedByNode,
MatchedEventMap matchEvent,
java.lang.Integer index)
|
void |
qPatternFollowedByQuit(EvalFollowedByNode evalFollowedByNode)
|
void |
qPatternFollowedByStart(EvalFollowedByNode evalFollowedByNode,
MatchedEventMap beginState)
|
void |
qPatternGuardEvaluateTrue(EvalGuardNode evalGuardNode,
MatchedEventMap matchEvent)
|
void |
qPatternGuardGuardQuit(EvalGuardNode evalGuardNode)
|
void |
qPatternGuardQuit(EvalGuardNode evalGuardNode)
|
void |
qPatternGuardScheduledEval()
|
void |
qPatternGuardStart(EvalGuardNode evalGuardNode,
MatchedEventMap beginState)
|
void |
qPatternMatchUntilEvalFalse(EvalMatchUntilNode evalMatchUntilNode,
boolean matchFromUntil)
|
void |
qPatternMatchUntilEvaluateTrue(EvalMatchUntilNode evalMatchUntilNode,
MatchedEventMap matchEvent,
boolean matchFromUntil)
|
void |
qPatternMatchUntilQuit(EvalMatchUntilNode evalMatchUntilNode)
|
void |
qPatternMatchUntilStart(EvalMatchUntilNode evalMatchUntilNode,
MatchedEventMap beginState)
|
void |
qPatternNotEvalFalse(EvalNotNode evalNotNode)
|
void |
qPatternNotEvaluateTrue(EvalNotNode evalNotNode,
MatchedEventMap matchEvent)
|
void |
qPatternNotQuit(EvalNotNode evalNotNode)
|
void |
qPatternNotStart(EvalNotNode evalNotNode,
MatchedEventMap beginState)
|
void |
qPatternObserverEvaluateTrue(EvalObserverNode evalObserverNode,
MatchedEventMap matchEvent)
|
void |
qPatternObserverQuit(EvalObserverNode evalObserverNode)
|
void |
qPatternObserverScheduledEval()
|
void |
qPatternObserverStart(EvalObserverNode evalObserverNode,
MatchedEventMap beginState)
|
void |
qPatternOrEvalFalse(EvalOrNode evalOrNode)
|
void |
qPatternOrEvaluateTrue(EvalOrNode evalOrNode,
MatchedEventMap matchEvent)
|
void |
qPatternOrQuit(EvalOrNode evalOrNode)
|
void |
qPatternOrStart(EvalOrNode evalOrNode,
MatchedEventMap beginState)
|
void |
qPatternRootEvalFalse()
|
void |
qPatternRootEvaluateTrue(MatchedEventMap matchEvent)
|
void |
qPatternRootQuit()
|
void |
qPatternRootStart(MatchedEventMap root)
|
void |
qRegEx(EventBean newEvent,
RegexPartitionState partitionState)
|
void |
qRegExPartition(ExprNode[] partitionExpressionNodes)
|
void |
qRegExScheduledEval()
|
void |
qRegExState(RegexNFAStateEntry currentState,
java.util.LinkedHashMap<java.lang.String,Pair<java.lang.Integer,java.lang.Boolean>> variableStreams,
int[] multimatchStreamNumToVariable)
|
void |
qRegIntervalState(RegexNFAStateEntry endState,
java.util.LinkedHashMap<java.lang.String,Pair<java.lang.Integer,java.lang.Boolean>> variableStreams,
int[] multimatchStreamNumToVariable,
long engineTime,
long intervalMSec)
|
void |
qRegIntervalValue(ExprNode exprNode)
|
void |
qRegMeasure(RegexNFAStateEntry endState,
java.util.LinkedHashMap<java.lang.String,Pair<java.lang.Integer,java.lang.Boolean>> variableStreams,
int[] multimatchStreamNumToVariable)
|
void |
qRegOut(EventBean[] outBeans)
|
void |
qResultSetProcessComputeGroupKeys(boolean enter,
ExprNode[] groupKeyNodeExpressions,
EventBean[] eventsPerStream)
|
void |
qResultSetProcessGroupedRowPerEvent()
|
void |
qResultSetProcessGroupedRowPerGroup()
|
void |
qResultSetProcessSimple()
|
void |
qResultSetProcessUngroupedFullyAgg()
|
void |
qResultSetProcessUngroupedNonfullyAgg()
|
void |
qRouteBetweenStmt(EventBean theEvent,
EPStatementHandle epStatementHandle,
boolean addToFront)
|
void |
qScheduleAdd(long currentTime,
long afterMSec,
ScheduleHandle handle,
ScheduleSlot slot)
|
void |
qScheduleEval(long currentTime)
|
void |
qScheduleRemove(ScheduleHandle handle,
ScheduleSlot slot)
|
void |
qSelectClause(EventBean[] eventsPerStream,
boolean newData,
boolean synthesize,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
qSplitStream(boolean all,
EventBean theEvent,
ExprEvaluator[] whereClauses)
|
void |
qSplitStreamRoute(int index)
|
void |
qSplitStreamWhere(int index)
|
void |
qStimulantEvent(EventBean eventBean,
java.lang.String engineURI)
|
void |
qStimulantTime(long currentTime,
java.lang.String engineURI)
|
void |
qSubselectAggregation(ExprNode optionalFilterExprNode)
|
void |
qTime(long engineTime,
java.lang.String engineURI)
|
void |
qTimeCP(EPStatementAgentInstanceHandle handle,
long engineTime)
|
void |
qUpdateIStream(InternalEventRouterEntry[] entries)
|
void |
qUpdateIStreamApply(int index,
InternalEventRouterEntry entry)
|
void |
qUpdateIStreamApplyAssignmentItem(int index)
|
void |
qUpdateIStreamApplyAssignments(InternalEventRouterEntry entry)
|
void |
qUpdateIStreamApplyWhere()
|
void |
qViewIndicate(View view,
java.lang.String viewName,
EventBean[] newData,
EventBean[] oldData)
|
void |
qViewProcessIRStream(View view,
java.lang.String viewName,
EventBean[] newData,
EventBean[] oldData)
|
void |
qViewScheduledEval(View view,
java.lang.String viewName)
|
void |
qWhereClauseFilter(ExprNode exprNode,
EventBean[] newData,
EventBean[] oldData)
|
void |
qWhereClauseFilterEval(int num,
EventBean event,
boolean newData)
|
void |
qWhereClauseIR(EventBean[] filteredNewData,
EventBean[] filteredOldData)
|
qStimulantEvent
void qStimulantEvent(EventBean eventBean,
java.lang.String engineURI)
aStimulantEvent
void aStimulantEvent()
qStimulantTime
void qStimulantTime(long currentTime,
java.lang.String engineURI)
aStimulantTime
void aStimulantTime()
qEvent
void qEvent(EventBean eventBean,
java.lang.String engineURI,
boolean providedBySendEvent)
aEvent
void aEvent()
qEventCP
void qEventCP(EventBean theEvent,
EPStatementAgentInstanceHandle handle,
long engineTime)
aEventCP
void aEventCP()
qTime
void qTime(long engineTime,
java.lang.String engineURI)
aTime
void aTime()
qTimeCP
void qTimeCP(EPStatementAgentInstanceHandle handle,
long engineTime)
aTimeCP
void aTimeCP()
qNamedWindowDispatch
void qNamedWindowDispatch(java.lang.String engineURI)
aNamedWindowDispatch
void aNamedWindowDispatch()
qNamedWindowCPSingle
void qNamedWindowCPSingle(java.lang.String engineURI,
java.util.List<NamedWindowConsumerView> value,
EventBean[] newData,
EventBean[] oldData,
EPStatementAgentInstanceHandle handle,
long time)
aNamedWindowCPSingle
void aNamedWindowCPSingle()
qNamedWindowCPMulti
void qNamedWindowCPMulti(java.lang.String engineURI,
java.util.Map<NamedWindowConsumerView,NamedWindowDeltaData> deltaPerConsumer,
EPStatementAgentInstanceHandle handle,
long time)
aNamedWindowCPMulti
void aNamedWindowCPMulti()
qRegEx
void qRegEx(EventBean newEvent,
RegexPartitionState partitionState)
aRegEx
void aRegEx(RegexPartitionState partitionState,
java.util.List<RegexNFAStateEntry> endStates,
java.util.List<RegexNFAStateEntry> terminationStates)
qRegExState
void qRegExState(RegexNFAStateEntry currentState,
java.util.LinkedHashMap<java.lang.String,Pair<java.lang.Integer,java.lang.Boolean>> variableStreams,
int[] multimatchStreamNumToVariable)
aRegExState
void aRegExState(java.util.List<RegexNFAStateEntry> next,
java.util.LinkedHashMap<java.lang.String,Pair<java.lang.Integer,java.lang.Boolean>> variableStreams,
int[] multimatchStreamNumToVariable)
qRegExPartition
void qRegExPartition(ExprNode[] partitionExpressionNodes)
aRegExPartition
void aRegExPartition(boolean exists,
RegexPartitionState state)
qRegIntervalValue
void qRegIntervalValue(ExprNode exprNode)
aRegIntervalValue
void aRegIntervalValue(long result)
qRegIntervalState
void qRegIntervalState(RegexNFAStateEntry endState,
java.util.LinkedHashMap<java.lang.String,Pair<java.lang.Integer,java.lang.Boolean>> variableStreams,
int[] multimatchStreamNumToVariable,
long engineTime,
long intervalMSec)
aRegIntervalState
void aRegIntervalState(boolean scheduled)
qRegOut
void qRegOut(EventBean[] outBeans)
aRegOut
void aRegOut()
qRegMeasure
void qRegMeasure(RegexNFAStateEntry endState,
java.util.LinkedHashMap<java.lang.String,Pair<java.lang.Integer,java.lang.Boolean>> variableStreams,
int[] multimatchStreamNumToVariable)
aRegMeasure
void aRegMeasure(EventBean outBean)
qRegExScheduledEval
void qRegExScheduledEval()
aRegExScheduledEval
void aRegExScheduledEval()
qExprBool
void qExprBool(ExprNode exprNode,
EventBean[] eventsPerStream)
aExprBool
void aExprBool(java.lang.Boolean result)
qExprValue
void qExprValue(ExprNode exprNode,
EventBean[] eventsPerStream)
aExprValue
void aExprValue(java.lang.Object result)
qExprEquals
void qExprEquals(ExprNode exprNode)
aExprEquals
void aExprEquals(java.lang.Boolean result)
qExprAnd
void qExprAnd(ExprNode exprNode)
aExprAnd
void aExprAnd(java.lang.Boolean result)
qExprLike
void qExprLike(ExprNode exprNode)
aExprLike
void aExprLike(java.lang.Boolean result)
qExprBitwise
void qExprBitwise(ExprNode exprNode,
BitWiseOpEnum bitWiseOpEnum)
aExprBitwise
void aExprBitwise(java.lang.Object result)
qExprMath
void qExprMath(ExprMathNode exprMathNode,
java.lang.String op)
aExprMath
void aExprMath(java.lang.Object result)
qExprRegexp
void qExprRegexp(ExprRegexpNode exprRegexpNode)
aExprRegexp
void aExprRegexp(java.lang.Boolean result)
qExprIdent
void qExprIdent(java.lang.String fullUnresolvedName)
aExprIdent
void aExprIdent(java.lang.Object result)
qExprTypeof
void qExprTypeof()
aExprTypeof
void aExprTypeof(java.lang.String typeName)
qExprOr
void qExprOr(ExprOrNode exprOrNode)
aExprOr
void aExprOr(java.lang.Boolean result)
qExprIn
void qExprIn(ExprInNodeImpl exprInNode)
aExprIn
void aExprIn(java.lang.Boolean result)
qExprCoalesce
void qExprCoalesce(ExprCoalesceNode exprCoalesceNode)
aExprCoalesce
void aExprCoalesce(java.lang.Object value)
qExprConcat
void qExprConcat(ExprConcatNode exprConcatNode)
aExprConcat
void aExprConcat(java.lang.String result)
qaExprConst
void qaExprConst(java.lang.Object result)
qaExprTimestamp
void qaExprTimestamp(ExprTimestampNode exprTimestampNode,
long value)
qExprBetween
void qExprBetween(ExprBetweenNodeImpl exprBetweenNode)
aExprBetween
void aExprBetween(java.lang.Boolean result)
qExprCast
void qExprCast(ExprCastNode exprCastNode)
aExprCast
void aExprCast(java.lang.Object result)
qExprCase
void qExprCase(ExprCaseNode exprCaseNode)
aExprCase
void aExprCase(java.lang.Object result)
qExprArray
void qExprArray(ExprArrayNode exprArrayNode)
aExprArray
void aExprArray(java.lang.Object result)
qExprEqualsAnyOrAll
void qExprEqualsAnyOrAll(ExprEqualsAllAnyNode exprEqualsAllAnyNode)
aExprEqualsAnyOrAll
void aExprEqualsAnyOrAll(java.lang.Boolean result)
qExprMinMaxRow
void qExprMinMaxRow(ExprMinMaxRowNode exprMinMaxRowNode)
aExprMinMaxRow
void aExprMinMaxRow(java.lang.Object result)
qExprNew
void qExprNew(ExprNewNode exprNewNode)
aExprNew
void aExprNew(java.util.Map<java.lang.String,java.lang.Object> props)
qExprNot
void qExprNot(ExprNotNode exprNotNode)
aExprNot
void aExprNot(java.lang.Boolean result)
qExprPropExists
void qExprPropExists(ExprPropertyExistsNode exprPropertyExistsNode)
aExprPropExists
void aExprPropExists(boolean exists)
qExprRelOpAnyOrAll
void qExprRelOpAnyOrAll(ExprRelationalOpAllAnyNode exprRelationalOpAllAnyNode,
java.lang.String op)
aExprRelOpAnyOrAll
void aExprRelOpAnyOrAll(java.lang.Boolean result)
qExprRelOp
void qExprRelOp(ExprRelationalOpNodeImpl exprRelationalOpNode,
java.lang.String op)
aExprRelOp
void aExprRelOp(java.lang.Boolean result)
qExprStreamUnd
void qExprStreamUnd(ExprStreamUnderlyingNodeImpl exprStreamUnderlyingNode)
aExprStreamUnd
void aExprStreamUnd(java.lang.Object result)
qExprStreamUndSelectClause
void qExprStreamUndSelectClause(ExprStreamUnderlyingNode undNode)
aExprStreamUndSelectClause
void aExprStreamUndSelectClause(EventBean event)
qExprIs
void qExprIs(ExprEqualsNodeImpl exprNode)
aExprIs
void aExprIs(boolean result)
qExprVariable
void qExprVariable(ExprVariableNodeImpl exprVariableNode)
aExprVariable
void aExprVariable(java.lang.Object value)
qExprTimePeriod
void qExprTimePeriod(ExprTimePeriodImpl exprTimePeriod)
aExprTimePeriod
void aExprTimePeriod(java.lang.Object result)
qExprInstanceof
void qExprInstanceof(ExprInstanceofNode exprInstanceofNode)
aExprInstanceof
void aExprInstanceof(java.lang.Boolean result)
qExprContextProp
void qExprContextProp(ExprContextPropertyNode exprContextPropertyNode)
aExprContextProp
void aExprContextProp(java.lang.Object result)
qExprPlugInSingleRow
void qExprPlugInSingleRow(java.lang.reflect.Method method)
aExprPlugInSingleRow
void aExprPlugInSingleRow(java.lang.Object result)
qaExprAggValue
void qaExprAggValue(ExprAggregateNodeBase exprAggregateNodeBase,
java.lang.Object value)
qExprSubselect
void qExprSubselect(ExprSubselectNode exprSubselectNode)
aExprSubselect
void aExprSubselect(java.lang.Object result)
qExprDot
void qExprDot(ExprDotNode exprDotNode)
aExprDot
void aExprDot(java.lang.Object result)
qExprDotChain
void qExprDotChain(ExpressionReturnType targetTypeInfo,
java.lang.Object target,
ExprDotEval[] evalUnpacking)
aExprDotChain
void aExprDotChain()
qExprDotChainElement
void qExprDotChainElement(int num,
ExprDotEval methodEval)
aExprDotChainElement
void aExprDotChainElement(ExpressionReturnType typeInfo,
java.lang.Object result)
qaExprIStream
void qaExprIStream(ExprIStreamNode exprIStreamNode,
boolean newData)
qExprDeclared
void qExprDeclared(ExpressionDeclItem parent)
aExprDeclared
void aExprDeclared(java.lang.Object value)
qExprPrev
void qExprPrev(ExprPreviousNode exprPreviousNode,
boolean newData)
aExprPrev
void aExprPrev(java.lang.Object result)
qExprPrior
void qExprPrior(ExprPriorNode exprPriorNode)
aExprPrior
void aExprPrior(java.lang.Object result)
qExprStreamUndMethod
void qExprStreamUndMethod(ExprDotNode exprDotEvalStreamMethod)
aExprStreamUndMethod
void aExprStreamUndMethod(java.lang.Object result)
qExprStreamEventMethod
void qExprStreamEventMethod(ExprDotNode exprDotNode)
aExprStreamEventMethod
void aExprStreamEventMethod(java.lang.Object result)
qScheduleAdd
void qScheduleAdd(long currentTime,
long afterMSec,
ScheduleHandle handle,
ScheduleSlot slot)
aScheduleAdd
void aScheduleAdd()
qScheduleRemove
void qScheduleRemove(ScheduleHandle handle,
ScheduleSlot slot)
aScheduleRemove
void aScheduleRemove()
qScheduleEval
void qScheduleEval(long currentTime)
aScheduleEval
void aScheduleEval(java.util.Collection<ScheduleHandle> handles)
qPatternAndEvaluateTrue
void qPatternAndEvaluateTrue(EvalAndNode evalAndNode,
MatchedEventMap passUp)
aPatternAndEvaluateTrue
void aPatternAndEvaluateTrue(boolean quitted)
qPatternAndQuit
void qPatternAndQuit(EvalAndNode evalAndNode)
aPatternAndQuit
void aPatternAndQuit()
qPatternAndEvaluateFalse
void qPatternAndEvaluateFalse(EvalAndNode evalAndNode)
aPatternAndEvaluateFalse
void aPatternAndEvaluateFalse()
qPatternAndStart
void qPatternAndStart(EvalAndNode evalAndNode,
MatchedEventMap beginState)
aPatternAndStart
void aPatternAndStart()
qPatternFollowedByEvaluateTrue
void qPatternFollowedByEvaluateTrue(EvalFollowedByNode evalFollowedByNode,
MatchedEventMap matchEvent,
java.lang.Integer index)
aPatternFollowedByEvaluateTrue
void aPatternFollowedByEvaluateTrue(boolean quitted)
qPatternFollowedByQuit
void qPatternFollowedByQuit(EvalFollowedByNode evalFollowedByNode)
aPatternFollowedByQuit
void aPatternFollowedByQuit()
qPatternFollowedByEvalFalse
void qPatternFollowedByEvalFalse(EvalFollowedByNode evalFollowedByNode)
aPatternFollowedByEvalFalse
void aPatternFollowedByEvalFalse()
qPatternFollowedByStart
void qPatternFollowedByStart(EvalFollowedByNode evalFollowedByNode,
MatchedEventMap beginState)
aPatternFollowedByStart
void aPatternFollowedByStart()
qPatternOrEvaluateTrue
void qPatternOrEvaluateTrue(EvalOrNode evalOrNode,
MatchedEventMap matchEvent)
aPatternOrEvaluateTrue
void aPatternOrEvaluateTrue(boolean quitted)
qPatternOrEvalFalse
void qPatternOrEvalFalse(EvalOrNode evalOrNode)
aPatternOrEvalFalse
void aPatternOrEvalFalse()
qPatternOrQuit
void qPatternOrQuit(EvalOrNode evalOrNode)
aPatternOrQuit
void aPatternOrQuit()
aPatternOrStart
void aPatternOrStart()
qPatternOrStart
void qPatternOrStart(EvalOrNode evalOrNode,
MatchedEventMap beginState)
qPatternFilterMatch
void qPatternFilterMatch(EvalFilterNode filterNode,
EventBean theEvent)
aPatternFilterMatch
void aPatternFilterMatch(boolean quitted)
qPatternFilterStart
void qPatternFilterStart(EvalFilterNode evalFilterNode,
MatchedEventMap beginState)
aPatternFilterStart
void aPatternFilterStart()
qPatternFilterQuit
void qPatternFilterQuit(EvalFilterNode evalFilterNode,
MatchedEventMap beginState)
aPatternFilterQuit
void aPatternFilterQuit()
qPatternRootEvaluateTrue
void qPatternRootEvaluateTrue(MatchedEventMap matchEvent)
aPatternRootEvaluateTrue
void aPatternRootEvaluateTrue(boolean quitted)
qPatternRootStart
void qPatternRootStart(MatchedEventMap root)
aPatternRootStart
void aPatternRootStart()
qPatternRootQuit
void qPatternRootQuit()
aPatternRootQuit
void aPatternRootQuit()
qPatternRootEvalFalse
void qPatternRootEvalFalse()
aPatternRootEvalFalse
void aPatternRootEvalFalse()
qPatternEveryEvaluateTrue
void qPatternEveryEvaluateTrue(EvalEveryNode evalEveryNode,
MatchedEventMap matchEvent)
aPatternEveryEvaluateTrue
void aPatternEveryEvaluateTrue()
qPatternEveryStart
void qPatternEveryStart(EvalEveryNode evalEveryNode,
MatchedEventMap beginState)
aPatternEveryStart
void aPatternEveryStart()
qPatternEveryEvalFalse
void qPatternEveryEvalFalse(EvalEveryNode evalEveryNode)
aPatternEveryEvalFalse
void aPatternEveryEvalFalse()
qPatternEveryQuit
void qPatternEveryQuit(EvalEveryNode evalEveryNode)
aPatternEveryQuit
void aPatternEveryQuit()
qPatternEveryDistinctEvaluateTrue
void qPatternEveryDistinctEvaluateTrue(EvalEveryDistinctNode everyDistinctNode,
MatchedEventMap matchEvent)
aPatternEveryDistinctEvaluateTrue
void aPatternEveryDistinctEvaluateTrue(java.util.Set<java.lang.Object> keysFromNodeNoExpire,
java.util.LinkedHashMap<java.lang.Object,java.lang.Long> keysFromNodeExpire,
java.lang.Object matchEventKey,
boolean haveSeenThis)
qPatternEveryDistinctQuit
void qPatternEveryDistinctQuit(EvalEveryDistinctNode everyNode)
aPatternEveryDistinctQuit
void aPatternEveryDistinctQuit()
qPatternEveryDistinctEvalFalse
void qPatternEveryDistinctEvalFalse(EvalEveryDistinctNode everyNode)
aPatternEveryDistinctEvalFalse
void aPatternEveryDistinctEvalFalse()
qPatternEveryDistinctStart
void qPatternEveryDistinctStart(EvalEveryDistinctNode everyNode,
MatchedEventMap beginState)
aPatternEveryDistinctStart
void aPatternEveryDistinctStart()
qPatternGuardEvaluateTrue
void qPatternGuardEvaluateTrue(EvalGuardNode evalGuardNode,
MatchedEventMap matchEvent)
aPatternGuardEvaluateTrue
void aPatternGuardEvaluateTrue(boolean quitted)
qPatternGuardStart
void qPatternGuardStart(EvalGuardNode evalGuardNode,
MatchedEventMap beginState)
aPatternGuardStart
void aPatternGuardStart()
qPatternGuardQuit
void qPatternGuardQuit(EvalGuardNode evalGuardNode)
aPatternGuardQuit
void aPatternGuardQuit()
qPatternGuardGuardQuit
void qPatternGuardGuardQuit(EvalGuardNode evalGuardNode)
aPatternGuardGuardQuit
void aPatternGuardGuardQuit()
qPatternGuardScheduledEval
void qPatternGuardScheduledEval()
aPatternGuardScheduledEval
void aPatternGuardScheduledEval()
qPatternMatchUntilEvaluateTrue
void qPatternMatchUntilEvaluateTrue(EvalMatchUntilNode evalMatchUntilNode,
MatchedEventMap matchEvent,
boolean matchFromUntil)
aPatternMatchUntilEvaluateTrue
void aPatternMatchUntilEvaluateTrue(boolean quitted)
qPatternMatchUntilStart
void qPatternMatchUntilStart(EvalMatchUntilNode evalMatchUntilNode,
MatchedEventMap beginState)
aPatternMatchUntilStart
void aPatternMatchUntilStart()
qPatternMatchUntilEvalFalse
void qPatternMatchUntilEvalFalse(EvalMatchUntilNode evalMatchUntilNode,
boolean matchFromUntil)
aPatternMatchUntilEvalFalse
void aPatternMatchUntilEvalFalse()
qPatternMatchUntilQuit
void qPatternMatchUntilQuit(EvalMatchUntilNode evalMatchUntilNode)
aPatternMatchUntilQuit
void aPatternMatchUntilQuit()
qPatternNotEvaluateTrue
void qPatternNotEvaluateTrue(EvalNotNode evalNotNode,
MatchedEventMap matchEvent)
aPatternNotEvaluateTrue
void aPatternNotEvaluateTrue(boolean quitted)
aPatternNotQuit
void aPatternNotQuit()
qPatternNotQuit
void qPatternNotQuit(EvalNotNode evalNotNode)
qPatternNotStart
void qPatternNotStart(EvalNotNode evalNotNode,
MatchedEventMap beginState)
aPatternNotStart
void aPatternNotStart()
qPatternNotEvalFalse
void qPatternNotEvalFalse(EvalNotNode evalNotNode)
aPatternNotEvalFalse
void aPatternNotEvalFalse()
qPatternObserverEvaluateTrue
void qPatternObserverEvaluateTrue(EvalObserverNode evalObserverNode,
MatchedEventMap matchEvent)
aPatternObserverEvaluateTrue
void aPatternObserverEvaluateTrue()
qPatternObserverStart
void qPatternObserverStart(EvalObserverNode evalObserverNode,
MatchedEventMap beginState)
aPatternObserverStart
void aPatternObserverStart()
qPatternObserverQuit
void qPatternObserverQuit(EvalObserverNode evalObserverNode)
aPatternObserverQuit
void aPatternObserverQuit()
qPatternObserverScheduledEval
void qPatternObserverScheduledEval()
aPatternObserverScheduledEval
void aPatternObserverScheduledEval()
qContextPartitionAllocate
void qContextPartitionAllocate(AgentInstanceContext agentInstanceContext)
aContextPartitionAllocate
void aContextPartitionAllocate()
qContextPartitionDestroy
void qContextPartitionDestroy(AgentInstanceContext agentInstanceContext)
aContextPartitionDestroy
void aContextPartitionDestroy()
qContextScheduledEval
void qContextScheduledEval(ContextDescriptor contextDescriptor)
aContextScheduledEval
void aContextScheduledEval()
qOutputProcessNonBuffered
void qOutputProcessNonBuffered(EventBean[] newData,
EventBean[] oldData)
aOutputProcessNonBuffered
void aOutputProcessNonBuffered()
qOutputProcessNonBufferedJoin
void qOutputProcessNonBufferedJoin(java.util.Set<MultiKey<EventBean>> newEvents,
java.util.Set<MultiKey<EventBean>> oldEvents)
aOutputProcessNonBufferedJoin
void aOutputProcessNonBufferedJoin()
qOutputProcessWCondition
void qOutputProcessWCondition(EventBean[] newData,
EventBean[] oldData)
aOutputProcessWCondition
void aOutputProcessWCondition(boolean buffered)
qOutputProcessWConditionJoin
void qOutputProcessWConditionJoin(java.util.Set<MultiKey<EventBean>> newEvents,
java.util.Set<MultiKey<EventBean>> oldEvents)
aOutputProcessWConditionJoin
void aOutputProcessWConditionJoin(boolean buffered)
qOutputRateConditionUpdate
void qOutputRateConditionUpdate(int newDataLength,
int oldDataLength)
aOutputRateConditionUpdate
void aOutputRateConditionUpdate()
qOutputRateConditionOutputNow
void qOutputRateConditionOutputNow()
aOutputRateConditionOutputNow
void aOutputRateConditionOutputNow(boolean generate)
qOutputRateConditionScheduledEval
void qOutputRateConditionScheduledEval()
aOutputRateConditionScheduledEval
void aOutputRateConditionScheduledEval()
qResultSetProcessSimple
void qResultSetProcessSimple()
aResultSetProcessSimple
void aResultSetProcessSimple(EventBean[] selectNewEvents,
EventBean[] selectOldEvents)
qResultSetProcessUngroupedFullyAgg
void qResultSetProcessUngroupedFullyAgg()
aResultSetProcessUngroupedFullyAgg
void aResultSetProcessUngroupedFullyAgg(EventBean[] selectNewEvents,
EventBean[] selectOldEvents)
qResultSetProcessUngroupedNonfullyAgg
void qResultSetProcessUngroupedNonfullyAgg()
aResultSetProcessUngroupedNonfullyAgg
void aResultSetProcessUngroupedNonfullyAgg(EventBean[] selectNewEvents,
EventBean[] selectOldEvents)
qResultSetProcessGroupedRowPerGroup
void qResultSetProcessGroupedRowPerGroup()
aResultSetProcessGroupedRowPerGroup
void aResultSetProcessGroupedRowPerGroup(EventBean[] selectNewEvents,
EventBean[] selectOldEvents)
qResultSetProcessGroupedRowPerEvent
void qResultSetProcessGroupedRowPerEvent()
aResultSetProcessGroupedRowPerEvent
void aResultSetProcessGroupedRowPerEvent(EventBean[] selectNewEvents,
EventBean[] selectOldEvents)
qResultSetProcessComputeGroupKeys
void qResultSetProcessComputeGroupKeys(boolean enter,
ExprNode[] groupKeyNodeExpressions,
EventBean[] eventsPerStream)
aResultSetProcessComputeGroupKeys
void aResultSetProcessComputeGroupKeys(boolean enter,
java.lang.Object groupKeysPerEvent)
qAggregationUngroupedApplyEnterLeave
void qAggregationUngroupedApplyEnterLeave(boolean enter,
int numAggregators,
int numAccessStates)
aAggregationUngroupedApplyEnterLeave
void aAggregationUngroupedApplyEnterLeave(boolean enter)
qAggregationGroupedApplyEnterLeave
void qAggregationGroupedApplyEnterLeave(boolean enter,
int numAggregators,
int numAccessStates,
java.lang.Object groupKey)
aAggregationGroupedApplyEnterLeave
void aAggregationGroupedApplyEnterLeave(boolean enter)
qAggNoAccessEnterLeave
void qAggNoAccessEnterLeave(boolean enter,
int index,
AggregationMethod aggregationMethod,
AggregationMethodFactory aggregationMethodFactory)
aAggNoAccessEnterLeave
void aAggNoAccessEnterLeave(boolean enter,
int index,
AggregationMethod aggregationMethod)
qAggAccessEnterLeave
void qAggAccessEnterLeave(boolean enter,
int index,
AggregationState state,
AggregationStateFactory accessAggSpec)
aAggAccessEnterLeave
void aAggAccessEnterLeave(boolean enter,
int index,
AggregationState state)
qSelectClause
void qSelectClause(EventBean[] eventsPerStream,
boolean newData,
boolean synthesize,
ExprEvaluatorContext exprEvaluatorContext)
aSelectClause
void aSelectClause(boolean newData,
EventBean event,
java.lang.Object[] subscriberParameters)
qViewProcessIRStream
void qViewProcessIRStream(View view,
java.lang.String viewName,
EventBean[] newData,
EventBean[] oldData)
aViewProcessIRStream
void aViewProcessIRStream()
qViewScheduledEval
void qViewScheduledEval(View view,
java.lang.String viewName)
aViewScheduledEval
void aViewScheduledEval()
qViewIndicate
void qViewIndicate(View view,
java.lang.String viewName,
EventBean[] newData,
EventBean[] oldData)
aViewIndicate
void aViewIndicate()
qSubselectAggregation
void qSubselectAggregation(ExprNode optionalFilterExprNode)
aSubselectAggregation
void aSubselectAggregation()
qFilterActivationSubselect
void qFilterActivationSubselect(java.lang.String eventTypeName,
ExprSubselectNode subselectNode)
aFilterActivationSubselect
void aFilterActivationSubselect()
qFilterActivationStream
void qFilterActivationStream(java.lang.String eventTypeName,
int streamNumber)
aFilterActivationStream
void aFilterActivationStream()
qFilterActivationNamedWindowInsert
void qFilterActivationNamedWindowInsert(java.lang.String namedWindowName)
aFilterActivationNamedWindowInsert
void aFilterActivationNamedWindowInsert()
qFilterActivationOnTrigger
void qFilterActivationOnTrigger(java.lang.String eventTypeName)
aFilterActivationOnTrigger
void aFilterActivationOnTrigger()
qRouteBetweenStmt
void qRouteBetweenStmt(EventBean theEvent,
EPStatementHandle epStatementHandle,
boolean addToFront)
aRouteBetweenStmt
void aRouteBetweenStmt()
qIndexAddRemove
void qIndexAddRemove(EventTable eventTable,
EventBean[] newData,
EventBean[] oldData)
aIndexAddRemove
void aIndexAddRemove()
qIndexAdd
void qIndexAdd(EventTable eventTable,
EventBean[] addEvents)
aIndexAdd
void aIndexAdd()
qIndexRemove
void qIndexRemove(EventTable eventTable,
EventBean[] removeEvents)
aIndexRemove
void aIndexRemove()
qIndexSubordLookup
void qIndexSubordLookup(SubordTableLookupStrategy subordTableLookupStrategy,
EventTable optionalEventIndex,
int[] keyStreamNums)
aIndexSubordLookup
void aIndexSubordLookup(java.util.Collection<EventBean> events,
java.lang.Object keys)
qIndexJoinLookup
void qIndexJoinLookup(JoinExecTableLookupStrategy strategy,
EventTable index)
aIndexJoinLookup
void aIndexJoinLookup(java.util.Set<EventBean> result,
java.lang.Object keys)
qFilter
void qFilter(EventBean theEvent)
aFilter
void aFilter(java.util.Collection<FilterHandle> matches)
qFilterHandleSetIndexes
void qFilterHandleSetIndexes(java.util.List<FilterParamIndexBase> indizes)
aFilterHandleSetIndexes
void aFilterHandleSetIndexes()
qaFilterHandleSetCallbacks
void qaFilterHandleSetCallbacks(java.util.Set<FilterHandle> callbackSet)
qFilterReverseIndex
void qFilterReverseIndex(FilterParamIndexLookupableBase filterParamIndex,
java.lang.Object propertyValue)
aFilterReverseIndex
void aFilterReverseIndex(java.lang.Boolean match)
qFilterBoolean
void qFilterBoolean(FilterParamIndexBooleanExpr filterParamIndexBooleanExpr)
aFilterBoolean
void aFilterBoolean()
qFilterBooleanExpr
void qFilterBooleanExpr(int num,
java.util.Map.Entry<ExprNodeAdapterBase,EventEvaluator> evals)
aFilterBooleanExpr
void aFilterBooleanExpr(boolean result)
qFilterAdd
void qFilterAdd(FilterValueSet filterValueSet,
FilterHandle filterCallback)
aFilterAdd
void aFilterAdd()
qFilterRemove
void qFilterRemove(FilterHandle filterCallback,
EventTypeIndexBuilderValueIndexesPair pair)
aFilterRemove
void aFilterRemove()
qWhereClauseFilter
void qWhereClauseFilter(ExprNode exprNode,
EventBean[] newData,
EventBean[] oldData)
aWhereClauseFilter
void aWhereClauseFilter(EventBean[] filteredNewData,
EventBean[] filteredOldData)
qWhereClauseFilterEval
void qWhereClauseFilterEval(int num,
EventBean event,
boolean newData)
aWhereClauseFilterEval
void aWhereClauseFilterEval(java.lang.Boolean pass)
qWhereClauseIR
void qWhereClauseIR(EventBean[] filteredNewData,
EventBean[] filteredOldData)
aWhereClauseIR
void aWhereClauseIR()
qHavingClauseNonJoin
void qHavingClauseNonJoin(EventBean theEvent)
aHavingClauseNonJoin
void aHavingClauseNonJoin(java.lang.Boolean pass)
qHavingClauseJoin
void qHavingClauseJoin(EventBean[] eventsPerStream)
aHavingClauseJoin
void aHavingClauseJoin(java.lang.Boolean pass)
qOrderBy
void qOrderBy(EventBean[] evalEventsPerStream,
OrderByElement[] orderBy)
aOrderBy
void aOrderBy(java.lang.Object values)
qJoinDispatch
void qJoinDispatch(EventBean[][] newDataPerStream,
EventBean[][] oldDataPerStream)
aJoinDispatch
void aJoinDispatch()
qJoinExexStrategy
void qJoinExexStrategy()
aJoinExecStrategy
void aJoinExecStrategy(UniformPair<java.util.Set<MultiKey<EventBean>>> joinSet)
qJoinExecFilter
void qJoinExecFilter()
aJoinExecFilter
void aJoinExecFilter(java.util.Set<MultiKey<EventBean>> newEvents,
java.util.Set<MultiKey<EventBean>> oldEvents)
qJoinExecProcess
void qJoinExecProcess(UniformPair<java.util.Set<MultiKey<EventBean>>> joinSet)
aJoinExecProcess
void aJoinExecProcess()
qJoinCompositionStreamToWin
void qJoinCompositionStreamToWin()
aJoinCompositionStreamToWin
void aJoinCompositionStreamToWin(java.util.Set<MultiKey<EventBean>> newResults)
qJoinCompositionWinToWin
void qJoinCompositionWinToWin()
aJoinCompositionWinToWin
void aJoinCompositionWinToWin(java.util.Set<MultiKey<EventBean>> newResults,
java.util.Set<MultiKey<EventBean>> oldResults)
qJoinCompositionHistorical
void qJoinCompositionHistorical()
aJoinCompositionHistorical
void aJoinCompositionHistorical(java.util.Set<MultiKey<EventBean>> newResults,
java.util.Set<MultiKey<EventBean>> oldResults)
qJoinCompositionStepUpdIndex
void qJoinCompositionStepUpdIndex(int stream,
EventBean[] added,
EventBean[] removed)
aJoinCompositionStepUpdIndex
void aJoinCompositionStepUpdIndex()
qJoinCompositionQueryStrategy
void qJoinCompositionQueryStrategy(boolean insert,
int streamNum,
EventBean[] events)
aJoinCompositionQueryStrategy
void aJoinCompositionQueryStrategy()
qNamedWindowTriggeredLookup
void qNamedWindowTriggeredLookup(NamedWindowLookupStrategyType lookupStrategy)
aNamedWindowTriggeredLookup
void aNamedWindowTriggeredLookup(EventBean[] result)
qNamedWindowOnAction
void qNamedWindowOnAction(OnTriggerType triggerType,
EventBean[] triggerEvents,
EventBean[] matchingEvents)
aNamedWindowOnAction
void aNamedWindowOnAction()
qNamedWindowUpdate
void qNamedWindowUpdate(EventBean matchingEvent,
EventBean[] eventsPerStream,
int length)
aNamedWindowUpdate
void aNamedWindowUpdate(EventBean copy)
qNamedWindowUpdateRHSExpr
void qNamedWindowUpdateRHSExpr(int index,
NamedWindowUpdateItem updateItem)
aNamedWindowUpdateRHSExpr
void aNamedWindowUpdateRHSExpr(java.lang.Object result)
qNamedWindowMergeWhenThens
void qNamedWindowMergeWhenThens(boolean matched,
EventBean triggerEvent,
java.util.List<NamedWindowOnMergeMatch> matchesSpec)
aNamedWindowMergeWhenThens
void aNamedWindowMergeWhenThens(boolean matched)
qNamedWindowMergeWhenThenItem
void qNamedWindowMergeWhenThenItem(boolean matched,
NamedWindowOnMergeMatch whenThen,
int count)
aNamedWindowMergeWhenThenItem
void aNamedWindowMergeWhenThenItem(boolean matched,
boolean actionsApplied)
qNamedWindowMergeWhenThenActions
void qNamedWindowMergeWhenThenActions(java.util.List<NamedWindowOnMergeAction> size)
aNamedWindowMergeWhenThenActions
void aNamedWindowMergeWhenThenActions()
qNamedWindowMergeWhenThenActionItem
void qNamedWindowMergeWhenThenActionItem(int count,
NamedWindowOnMergeAction action)
aNamedWindowMergeWhenThenActionItem
void aNamedWindowMergeWhenThenActionItem(boolean applies)
qEngineManagementStmtCompileStart
void qEngineManagementStmtCompileStart(java.lang.String engineURI,
java.lang.String statementId,
java.lang.String statementName,
java.lang.String epl,
long engineTime)
aEngineManagementStmtCompileStart
void aEngineManagementStmtCompileStart(boolean success,
java.lang.String message)
qaEngineManagementStmtStarted
void qaEngineManagementStmtStarted(java.lang.String engineURI,
java.lang.String statementId,
java.lang.String statementName,
java.lang.String epl,
long engineTime)
qEngineManagementStmtStop
void qEngineManagementStmtStop(EPStatementState targetState,
java.lang.String engineURI,
java.lang.String statementId,
java.lang.String statementName,
java.lang.String epl,
long engineTime)
aEngineManagementStmtStop
void aEngineManagementStmtStop()
qaStatementResultExecute
void qaStatementResultExecute(UniformPair<EventBean[]> events,
java.lang.String statementId,
java.lang.String statementName,
int agentInstanceId,
long threadId)
qSplitStream
void qSplitStream(boolean all,
EventBean theEvent,
ExprEvaluator[] whereClauses)
aSplitStream
void aSplitStream(boolean all,
boolean handled)
qSplitStreamWhere
void qSplitStreamWhere(int index)
aSplitStreamWhere
void aSplitStreamWhere(java.lang.Boolean pass)
qSplitStreamRoute
void qSplitStreamRoute(int index)
aSplitStreamRoute
void aSplitStreamRoute()
qUpdateIStream
void qUpdateIStream(InternalEventRouterEntry[] entries)
aUpdateIStream
void aUpdateIStream(EventBean finalEvent,
boolean haveCloned)
qUpdateIStreamApply
void qUpdateIStreamApply(int index,
InternalEventRouterEntry entry)
aUpdateIStreamApply
void aUpdateIStreamApply(EventBean updated,
boolean applied)
qUpdateIStreamApplyWhere
void qUpdateIStreamApplyWhere()
aUpdateIStreamApplyWhere
void aUpdateIStreamApplyWhere(java.lang.Boolean result)
qUpdateIStreamApplyAssignments
void qUpdateIStreamApplyAssignments(InternalEventRouterEntry entry)
aUpdateIStreamApplyAssignments
void aUpdateIStreamApplyAssignments(java.lang.Object[] values)
qUpdateIStreamApplyAssignmentItem
void qUpdateIStreamApplyAssignmentItem(int index)
aUpdateIStreamApplyAssignmentItem
void aUpdateIStreamApplyAssignmentItem(java.lang.Object value)
qHistoricalScheduledEval
void qHistoricalScheduledEval()
aHistoricalScheduledEval
void aHistoricalScheduledEval()