Interface InstrumentationCommon
- All Known Implementing Classes:
InstrumentationCommonDefault
public interface InstrumentationCommon
-
Field Summary
Modifier and TypeFieldDescriptionstatic final EPTypeClass
static final String
static final String
static final String
-
Method Summary
Modifier and TypeMethodDescriptionvoid
aAggAccessEnterLeave
(boolean enter, int index) void
aAggNoAccessEnterLeave
(boolean enter, int index, Object newValue) void
aAggregationGroupedApplyEnterLeave
(boolean enter) void
void
void
boolean
void
aFilterActivationStream
(AgentInstanceContext agentInstanceContext, boolean subselect, int subselectNumber) void
void
void
void
aIndexJoinLookup
(Set<EventBean> result, Object keys) void
void
aIndexSubordLookup
(Collection<EventBean> events, Object keys) void
aInfraMergeWhenThenActionItem
(boolean applies) void
void
aInfraMergeWhenThenItem
(boolean matched, boolean actionsApplied) void
aInfraMergeWhenThens
(boolean matched) void
void
aInfraTriggeredLookup
(EventBean[] result) void
aJoinCompositionHistorical
(Set<MultiKeyArrayOfKeys<EventBean>> newResults, Set<MultiKeyArrayOfKeys<EventBean>> oldResults) void
void
void
aJoinCompositionStreamToWin
(Set<MultiKeyArrayOfKeys<EventBean>> newResults) void
aJoinCompositionWinToWin
(Set<MultiKeyArrayOfKeys<EventBean>> newResults, Set<MultiKeyArrayOfKeys<EventBean>> oldResults) void
void
aJoinExecFilter
(Set<MultiKeyArrayOfKeys<EventBean>> newEvents, Set<MultiKeyArrayOfKeys<EventBean>> oldEvents) void
void
aJoinExecStrategy
(UniformPair<Set<MultiKeyArrayOfKeys<EventBean>>> joinSet) void
void
void
void
void
void
aOutputProcessWCondition
(boolean buffered) void
aOutputProcessWConditionJoin
(boolean buffered) void
aOutputRateConditionOutputNow
(boolean generate) void
void
void
void
aPatternAndEvaluateTrue
(boolean quitted) void
void
void
void
aPatternEveryDistinctEvaluateTrue
(Set<Object> keysFromNodeNoExpire, LinkedHashMap<Object, Long> keysFromNodeExpire, Object matchEventKey, boolean haveSeenThis) void
void
void
void
void
void
void
aPatternFilterMatch
(boolean quitted) void
void
void
void
aPatternFollowedByEvaluateTrue
(boolean quitted) void
void
void
void
aPatternGuardEvaluateTrue
(boolean quitted) void
void
void
void
void
void
aPatternMatchUntilEvaluateTrue
(boolean quitted) void
void
void
void
aPatternNotEvaluateTrue
(boolean quitted) void
void
void
void
void
void
void
void
aPatternOrEvaluateTrue
(boolean quitted) void
void
void
void
aPatternRootEvaluateTrue
(boolean quitted) void
void
void
aRegEx
(RowRecogPartitionState partitionState, List<RowRecogNFAStateEntry> endStates, List<RowRecogNFAStateEntry> terminationStates) void
aRegExPartition
(boolean exists, Object partitionKey, RowRecogPartitionState state) void
void
aRegExState
(List<RowRecogNFAStateEntry> next, LinkedHashMap<String, Pair<Integer, Boolean>> variableStreams, int[] multimatchStreamNumToVariable) void
aRegExStateStart
(List<RowRecogNFAStateEntry> nextStates, LinkedHashMap<String, Pair<Integer, Boolean>> variableStreams, int[] multimatchStreamNumToVariable) void
aRegFilter
(Boolean result) void
aRegIntervalState
(boolean scheduled) void
aRegIntervalValue
(long result) void
aRegMeasure
(EventBean outBean) void
aRegOut()
void
aSplitStream
(boolean all, boolean handled) void
void
aSplitStreamWhere
(Boolean pass) void
void
void
void
void
aUpdateIStream
(EventBean finalEvent, boolean haveCloned) void
aUpdateIStreamApply
(EventBean updated, boolean applied) void
void
aUpdateIStreamApplyAssignments
(Object[] values) void
aUpdateIStreamApplyWhere
(Boolean result) void
void
void
void
aWhereClauseFilter
(EventBean[] filteredNewData, EventBean[] filteredOldData) void
void
void
qAggAccessEnterLeave
(boolean enter, int index, String aggExpr) void
qAggNoAccessEnterLeave
(boolean enter, int index, Object currentValue, String aggExpression) void
qAggregationGroupedApplyEnterLeave
(boolean enter, int numAggregators, int numAccessStates, Object groupKey) void
qaTableUpdatedEventWKeyAfter
(EventBean theEvent) void
qaTableUpdatedEventWKeyBefore
(EventBean theEvent) void
qContextPartitionAllocate
(AgentInstanceContext agentInstanceContext) void
qContextPartitionDestroy
(AgentInstanceContext agentInstanceContext) void
qContextScheduledEval
(ContextRuntimeDescriptor contextDescriptor) void
qFilterActivationStream
(String eventTypeName, int streamNumber, AgentInstanceContext agentInstanceContext, boolean subselect, int subselectNumber) void
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
qInfraMergeWhenThenActionItem
(int count, String actionName) void
qInfraMergeWhenThenActions
(int numActions) void
qInfraMergeWhenThenItem
(boolean matched, int count) void
qInfraMergeWhenThens
(boolean matched, EventBean triggerEvent, int numWhenThens) void
qInfraOnAction
(OnTriggerType triggerType, EventBean[] triggerEvents, EventBean[] matchingEvents) void
qInfraTriggeredLookup
(String lookupStrategy) void
void
qJoinCompositionQueryStrategy
(boolean insert, int streamNum, EventBean[] events) void
qJoinCompositionStepUpdIndex
(int stream, EventBean[] added, EventBean[] removed) void
void
void
qJoinDispatch
(EventBean[][] newDataPerStream, EventBean[][] oldDataPerStream) void
void
qJoinExecProcess
(UniformPair<Set<MultiKeyArrayOfKeys<EventBean>>> joinSet) void
void
qNamedWindowCPMulti
(String runtimeURI, Map<NamedWindowConsumerView, NamedWindowDeltaData> deltaPerConsumer, EPStatementAgentInstanceHandle handle, long time) void
qNamedWindowCPSingle
(String runtimeURI, int numConsumers, EventBean[] newData, EventBean[] oldData, EPStatementAgentInstanceHandle handle, long time) void
qNamedWindowDispatch
(String runtimeURI) void
qOutputProcessNonBuffered
(EventBean[] newData, EventBean[] oldData) void
qOutputProcessNonBufferedJoin
(Set<MultiKeyArrayOfKeys<EventBean>> newEvents, Set<MultiKeyArrayOfKeys<EventBean>> oldEvents) void
qOutputProcessWCondition
(EventBean[] newData, EventBean[] oldData) void
qOutputProcessWConditionJoin
(Set<MultiKeyArrayOfKeys<EventBean>> newEvents, Set<MultiKeyArrayOfKeys<EventBean>> oldEvents) void
void
void
qOutputRateConditionUpdate
(int newDataLength, int oldDataLength) void
qPatternAndEvaluateFalse
(EvalAndFactoryNode evalAndNode) void
qPatternAndEvaluateTrue
(EvalAndFactoryNode evalAndNode, MatchedEventMap passUp) void
qPatternAndQuit
(EvalAndFactoryNode evalAndNode) void
qPatternAndStart
(EvalAndFactoryNode evalAndNode, MatchedEventMap beginState) void
void
qPatternEveryDistinctEvaluateTrue
(EvalEveryDistinctFactoryNode everyDistinctNode, MatchedEventMap matchEvent) void
void
qPatternEveryDistinctStart
(EvalEveryDistinctFactoryNode everyNode, MatchedEventMap beginState) void
qPatternEveryEvalFalse
(EvalEveryFactoryNode evalEveryNode) void
qPatternEveryEvaluateTrue
(EvalEveryFactoryNode evalEveryNode, MatchedEventMap matchEvent) void
qPatternEveryQuit
(EvalEveryFactoryNode evalEveryNode) void
qPatternEveryStart
(EvalEveryFactoryNode evalEveryNode, MatchedEventMap beginState) void
qPatternFilterMatch
(EvalFilterFactoryNode filterNode, EventBean theEvent) void
qPatternFilterQuit
(EvalFilterFactoryNode evalFilterNode, MatchedEventMap beginState) void
qPatternFilterStart
(EvalFilterFactoryNode evalFilterNode, MatchedEventMap beginState) void
qPatternFollowedByEvalFalse
(EvalFollowedByFactoryNode evalFollowedByNode) void
qPatternFollowedByEvaluateTrue
(EvalFollowedByFactoryNode evalFollowedByNode, MatchedEventMap matchEvent, Integer index) void
qPatternFollowedByQuit
(EvalFollowedByFactoryNode evalFollowedByNode) void
qPatternFollowedByStart
(EvalFollowedByFactoryNode evalFollowedByNode, MatchedEventMap beginState) void
qPatternGuardEvalFalse
(EvalGuardFactoryNode evalGuardNode) void
qPatternGuardEvaluateTrue
(EvalGuardFactoryNode evalGuardNode, MatchedEventMap matchEvent) void
qPatternGuardGuardQuit
(EvalGuardFactoryNode evalGuardNode) void
qPatternGuardQuit
(EvalGuardFactoryNode evalGuardNode) void
void
qPatternGuardStart
(EvalGuardFactoryNode evalGuardNode, MatchedEventMap beginState) void
qPatternMatchUntilEvalFalse
(EvalMatchUntilFactoryNode evalMatchUntilNode, boolean matchFromUntil) void
qPatternMatchUntilEvaluateTrue
(EvalMatchUntilFactoryNode evalMatchUntilNode, MatchedEventMap matchEvent, boolean matchFromUntil) void
qPatternMatchUntilQuit
(EvalMatchUntilFactoryNode evalMatchUntilNode) void
qPatternMatchUntilStart
(EvalMatchUntilFactoryNode evalMatchUntilNode, MatchedEventMap beginState) void
qPatternNotEvalFalse
(EvalNotFactoryNode evalNotNode) void
qPatternNotEvaluateTrue
(EvalNotFactoryNode evalNotNode, MatchedEventMapMinimal matchEvent) void
qPatternNotQuit
(EvalNotFactoryNode evalNotNode) void
qPatternNotStart
(EvalNotFactoryNode evalNotNode, MatchedEventMap beginState) void
qPatternObserverEvaluateTrue
(EvalObserverFactoryNode evalObserverNode, MatchedEventMap matchEvent) void
qPatternObserverQuit
(EvalObserverFactoryNode evalObserverNode) void
void
qPatternObserverStart
(EvalObserverFactoryNode evalObserverNode, MatchedEventMap beginState) void
qPatternOrEvalFalse
(EvalOrFactoryNode evalOrNode) void
qPatternOrEvaluateTrue
(EvalOrFactoryNode evalOrNode, MatchedEventMap matchEvent) void
qPatternOrQuit
(EvalOrFactoryNode evalOrNode) void
qPatternOrStart
(EvalOrFactoryNode evalOrNode, MatchedEventMap beginState) void
void
qPatternRootEvaluateTrue
(MatchedEventMap matchEvent) void
void
void
qRegEx
(EventBean newEvent, RowRecogPartitionState partitionState) void
qRegExPartition
(EventBean theEvent) void
void
qRegExState
(RowRecogNFAStateEntry currentState, LinkedHashMap<String, Pair<Integer, Boolean>> variableStreams, int[] multimatchStreamNumToVariable) void
qRegExStateStart
(RowRecogNFAState startState, LinkedHashMap<String, Pair<Integer, Boolean>> variableStreams, int[] multimatchStreamNumToVariable) void
qRegFilter
(String text, EventBean[] eventsPerStream) void
qRegIntervalState
(RowRecogNFAStateEntry endState, LinkedHashMap<String, Pair<Integer, Boolean>> variableStreams, int[] multimatchStreamNumToVariable, long runtimeTime) void
void
qRegMeasure
(RowRecogNFAStateEntry endState, LinkedHashMap<String, Pair<Integer, Boolean>> variableStreams, int[] multimatchStreamNumToVariable) void
void
qSplitStream
(boolean all, EventBean theEvent, int numWhereClauses) void
qSplitStreamRoute
(int index) void
qSplitStreamWhere
(int index) void
void
qTableAddEvent
(EventBean theEvent) void
qTableDeleteEvent
(EventBean theEvent) void
qTableUpdatedEvent
(EventBean theEvent) void
qUpdateIStream
(InternalEventRouterEntry[] entries) void
qUpdateIStreamApply
(int index, InternalEventRouterEntry entry) void
qUpdateIStreamApplyAssignmentItem
(int index) void
void
void
qViewIndicate
(ViewFactory viewFactory, EventBean[] newData, EventBean[] oldData) void
qViewProcessIRStream
(ViewFactory viewFactory, EventBean[] newData, EventBean[] oldData) void
qViewScheduledEval
(ViewFactory viewFactory) void
qWhereClauseFilter
(String text, EventBean[] newData, EventBean[] oldData) void
qWhereClauseFilterEval
(int num, EventBean event, boolean newData) void
qWhereClauseIR
(EventBean[] filteredNewData, EventBean[] filteredOldData)
-
Field Details
-
EPTYPE
-
RUNTIME_PACKAGE_NAME
- See Also:
-
RUNTIME_DEFAULT_CLASS
- See Also:
-
RUNTIME_HELPER_CLASS
- See Also:
-
-
Method Details
-
activated
boolean activated() -
qNamedWindowDispatch
-
aNamedWindowDispatch
void aNamedWindowDispatch() -
qNamedWindowCPSingle
void qNamedWindowCPSingle(String runtimeURI, int numConsumers, EventBean[] newData, EventBean[] oldData, EPStatementAgentInstanceHandle handle, long time) -
aNamedWindowCPSingle
void aNamedWindowCPSingle() -
qNamedWindowCPMulti
void qNamedWindowCPMulti(String runtimeURI, Map<NamedWindowConsumerView, NamedWindowDeltaData> deltaPerConsumer, EPStatementAgentInstanceHandle handle, long time) -
aNamedWindowCPMulti
void aNamedWindowCPMulti() -
qRegEx
-
aRegEx
void aRegEx(RowRecogPartitionState partitionState, List<RowRecogNFAStateEntry> endStates, List<RowRecogNFAStateEntry> terminationStates) -
qRegExState
void qRegExState(RowRecogNFAStateEntry currentState, LinkedHashMap<String, Pair<Integer, Boolean>> variableStreams, int[] multimatchStreamNumToVariable) -
aRegExState
void aRegExState(List<RowRecogNFAStateEntry> next, LinkedHashMap<String, Pair<Integer, Boolean>> variableStreams, int[] multimatchStreamNumToVariable) -
qRegExStateStart
void qRegExStateStart(RowRecogNFAState startState, LinkedHashMap<String, Pair<Integer, Boolean>> variableStreams, int[] multimatchStreamNumToVariable) -
aRegExStateStart
void aRegExStateStart(List<RowRecogNFAStateEntry> nextStates, LinkedHashMap<String, Pair<Integer, Boolean>> variableStreams, int[] multimatchStreamNumToVariable) -
qRegExPartition
-
aRegExPartition
-
qRegIntervalValue
void qRegIntervalValue() -
aRegIntervalValue
void aRegIntervalValue(long result) -
qRegIntervalState
void qRegIntervalState(RowRecogNFAStateEntry endState, LinkedHashMap<String, Pair<Integer, Boolean>> variableStreams, int[] multimatchStreamNumToVariable, long runtimeTime) -
aRegIntervalState
void aRegIntervalState(boolean scheduled) -
qRegOut
-
aRegOut
void aRegOut() -
qRegMeasure
void qRegMeasure(RowRecogNFAStateEntry endState, LinkedHashMap<String, Pair<Integer, Boolean>> variableStreams, int[] multimatchStreamNumToVariable) -
aRegMeasure
-
qRegExScheduledEval
void qRegExScheduledEval() -
aRegExScheduledEval
void aRegExScheduledEval() -
qRegFilter
-
aRegFilter
-
qFilterActivationStream
void qFilterActivationStream(String eventTypeName, int streamNumber, AgentInstanceContext agentInstanceContext, boolean subselect, int subselectNumber) -
aFilterActivationStream
void aFilterActivationStream(AgentInstanceContext agentInstanceContext, boolean subselect, int subselectNumber) -
qIndexSubordLookup
void qIndexSubordLookup(SubordTableLookupStrategy subordTableLookupStrategy, EventTable optionalEventIndex, int[] keyStreamNums) -
aIndexSubordLookup
-
qViewProcessIRStream
-
aViewProcessIRStream
void aViewProcessIRStream() -
qViewIndicate
-
aViewIndicate
void aViewIndicate() -
qViewScheduledEval
-
aViewScheduledEval
void aViewScheduledEval() -
qPatternFilterMatch
-
aPatternFilterMatch
void aPatternFilterMatch(boolean quitted) -
qPatternNotEvaluateTrue
-
aPatternNotEvaluateTrue
void aPatternNotEvaluateTrue(boolean quitted) -
qPatternObserverQuit
-
aPatternObserverQuit
void aPatternObserverQuit() -
qPatternAndEvaluateFalse
-
aPatternAndEvaluateFalse
void aPatternAndEvaluateFalse() -
qPatternRootEvalFalse
void qPatternRootEvalFalse() -
aPatternRootEvalFalse
void aPatternRootEvalFalse() -
qPatternObserverScheduledEval
void qPatternObserverScheduledEval() -
aPatternObserverScheduledEval
void aPatternObserverScheduledEval() -
qPatternObserverEvaluateTrue
void qPatternObserverEvaluateTrue(EvalObserverFactoryNode evalObserverNode, MatchedEventMap matchEvent) -
aPatternObserverEvaluateTrue
void aPatternObserverEvaluateTrue() -
qPatternFollowedByEvaluateTrue
void qPatternFollowedByEvaluateTrue(EvalFollowedByFactoryNode evalFollowedByNode, MatchedEventMap matchEvent, Integer index) -
aPatternFollowedByEvaluateTrue
void aPatternFollowedByEvaluateTrue(boolean quitted) -
qPatternGuardStart
-
aPatternGuardStart
void aPatternGuardStart() -
qPatternAndStart
-
aPatternAndStart
void aPatternAndStart() -
qPatternFilterStart
-
aPatternFilterStart
void aPatternFilterStart() -
qPatternNotStart
-
aPatternNotStart
void aPatternNotStart() -
qPatternAndEvaluateTrue
-
aPatternAndEvaluateTrue
void aPatternAndEvaluateTrue(boolean quitted) -
qPatternGuardScheduledEval
void qPatternGuardScheduledEval() -
aPatternGuardScheduledEval
void aPatternGuardScheduledEval() -
qPatternGuardGuardQuit
-
aPatternGuardGuardQuit
void aPatternGuardGuardQuit() -
qPatternAndQuit
-
aPatternAndQuit
void aPatternAndQuit() -
qPatternFilterQuit
-
aPatternFilterQuit
void aPatternFilterQuit() -
qPatternNotQuit
-
aPatternNotQuit
void aPatternNotQuit() -
qPatternNotEvalFalse
-
aPatternNotEvalFalse
void aPatternNotEvalFalse() -
qPatternRootEvaluateTrue
-
aPatternRootEvaluateTrue
void aPatternRootEvaluateTrue(boolean quitted) -
qPatternObserverStart
-
aPatternObserverStart
void aPatternObserverStart() -
qPatternMatchUntilEvaluateTrue
void qPatternMatchUntilEvaluateTrue(EvalMatchUntilFactoryNode evalMatchUntilNode, MatchedEventMap matchEvent, boolean matchFromUntil) -
aPatternMatchUntilEvaluateTrue
void aPatternMatchUntilEvaluateTrue(boolean quitted) -
qPatternMatchUntilStart
void qPatternMatchUntilStart(EvalMatchUntilFactoryNode evalMatchUntilNode, MatchedEventMap beginState) -
aPatternMatchUntilStart
void aPatternMatchUntilStart() -
qPatternMatchUntilQuit
-
aPatternMatchUntilQuit
void aPatternMatchUntilQuit() -
qPatternMatchUntilEvalFalse
void qPatternMatchUntilEvalFalse(EvalMatchUntilFactoryNode evalMatchUntilNode, boolean matchFromUntil) -
aPatternMatchUntilEvalFalse
void aPatternMatchUntilEvalFalse() -
qPatternGuardEvaluateTrue
-
aPatternGuardEvaluateTrue
void aPatternGuardEvaluateTrue(boolean quitted) -
qPatternGuardQuit
-
aPatternGuardQuit
void aPatternGuardQuit() -
qPatternEveryDistinctEvaluateTrue
void qPatternEveryDistinctEvaluateTrue(EvalEveryDistinctFactoryNode everyDistinctNode, MatchedEventMap matchEvent) -
aPatternEveryDistinctEvaluateTrue
-
qPatternEveryDistinctStart
-
aPatternEveryDistinctStart
void aPatternEveryDistinctStart() -
qPatternEveryDistinctQuit
-
aPatternEveryDistinctQuit
void aPatternEveryDistinctQuit() -
qPatternFollowedByEvalFalse
-
aPatternFollowedByEvalFalse
void aPatternFollowedByEvalFalse() -
qPatternEveryDistinctEvalFalse
-
aPatternEveryDistinctEvalFalse
void aPatternEveryDistinctEvalFalse() -
qPatternEveryEvaluateTrue
-
aPatternEveryEvaluateTrue
void aPatternEveryEvaluateTrue() -
qPatternEveryStart
-
aPatternEveryStart
void aPatternEveryStart() -
qPatternEveryQuit
-
aPatternEveryQuit
void aPatternEveryQuit() -
qPatternEveryEvalFalse
-
aPatternEveryEvalFalse
void aPatternEveryEvalFalse() -
qPatternOrEvaluateTrue
-
aPatternOrEvaluateTrue
void aPatternOrEvaluateTrue(boolean quitted) -
qPatternOrStart
-
aPatternOrStart
void aPatternOrStart() -
qPatternOrQuit
-
aPatternOrQuit
void aPatternOrQuit() -
qPatternOrEvalFalse
-
aPatternOrEvalFalse
void aPatternOrEvalFalse() -
qPatternFollowedByStart
void qPatternFollowedByStart(EvalFollowedByFactoryNode evalFollowedByNode, MatchedEventMap beginState) -
aPatternFollowedByStart
void aPatternFollowedByStart() -
qPatternFollowedByQuit
-
aPatternFollowedByQuit
void aPatternFollowedByQuit() -
qPatternGuardEvalFalse
-
aPatternGuardEvalFalse
void aPatternGuardEvalFalse() -
qContextScheduledEval
-
aContextScheduledEval
void aContextScheduledEval() -
qContextPartitionAllocate
-
aContextPartitionAllocate
void aContextPartitionAllocate() -
qContextPartitionDestroy
-
aContextPartitionDestroy
void aContextPartitionDestroy() -
qPatternRootStart
-
aPatternRootStart
void aPatternRootStart() -
qPatternRootQuit
void qPatternRootQuit() -
aPatternRootQuit
void aPatternRootQuit() -
qInfraOnAction
void qInfraOnAction(OnTriggerType triggerType, EventBean[] triggerEvents, EventBean[] matchingEvents) -
aInfraOnAction
void aInfraOnAction() -
qTableUpdatedEvent
-
aTableUpdatedEvent
void aTableUpdatedEvent() -
qInfraMergeWhenThens
-
aInfraMergeWhenThens
void aInfraMergeWhenThens(boolean matched) -
qInfraMergeWhenThenItem
void qInfraMergeWhenThenItem(boolean matched, int count) -
aInfraMergeWhenThenItem
void aInfraMergeWhenThenItem(boolean matched, boolean actionsApplied) -
qInfraMergeWhenThenActions
void qInfraMergeWhenThenActions(int numActions) -
aInfraMergeWhenThenActions
void aInfraMergeWhenThenActions() -
qInfraMergeWhenThenActionItem
-
aInfraMergeWhenThenActionItem
void aInfraMergeWhenThenActionItem(boolean applies) -
qInfraTriggeredLookup
-
aInfraTriggeredLookup
-
qIndexJoinLookup
-
aIndexJoinLookup
-
qJoinDispatch
-
aJoinDispatch
void aJoinDispatch() -
qJoinExecStrategy
void qJoinExecStrategy() -
aJoinExecStrategy
-
qJoinCompositionStreamToWin
void qJoinCompositionStreamToWin() -
aJoinCompositionStreamToWin
-
qJoinCompositionStepUpdIndex
-
aJoinCompositionStepUpdIndex
void aJoinCompositionStepUpdIndex() -
qIndexAddRemove
-
aIndexAddRemove
void aIndexAddRemove() -
qIndexAdd
-
aIndexAdd
void aIndexAdd() -
qIndexRemove
-
aIndexRemove
void aIndexRemove() -
qJoinCompositionQueryStrategy
-
aJoinCompositionQueryStrategy
void aJoinCompositionQueryStrategy() -
qJoinExecProcess
-
aJoinExecProcess
void aJoinExecProcess() -
qJoinCompositionWinToWin
void qJoinCompositionWinToWin() -
aJoinCompositionWinToWin
void aJoinCompositionWinToWin(Set<MultiKeyArrayOfKeys<EventBean>> newResults, Set<MultiKeyArrayOfKeys<EventBean>> oldResults) -
qOutputProcessWCondition
-
aOutputProcessWCondition
void aOutputProcessWCondition(boolean buffered) -
qOutputRateConditionUpdate
void qOutputRateConditionUpdate(int newDataLength, int oldDataLength) -
aOutputRateConditionUpdate
void aOutputRateConditionUpdate() -
qOutputRateConditionOutputNow
void qOutputRateConditionOutputNow() -
aOutputRateConditionOutputNow
void aOutputRateConditionOutputNow(boolean generate) -
qOutputProcessWConditionJoin
void qOutputProcessWConditionJoin(Set<MultiKeyArrayOfKeys<EventBean>> newEvents, Set<MultiKeyArrayOfKeys<EventBean>> oldEvents) -
aOutputProcessWConditionJoin
void aOutputProcessWConditionJoin(boolean buffered) -
qWhereClauseFilter
-
aWhereClauseFilter
-
qWhereClauseFilterEval
-
aWhereClauseFilterEval
-
qWhereClauseIR
-
aWhereClauseIR
void aWhereClauseIR() -
qSplitStream
-
aSplitStream
void aSplitStream(boolean all, boolean handled) -
qSplitStreamWhere
void qSplitStreamWhere(int index) -
aSplitStreamWhere
-
qSplitStreamRoute
void qSplitStreamRoute(int index) -
aSplitStreamRoute
void aSplitStreamRoute() -
qSubselectAggregation
void qSubselectAggregation() -
aSubselectAggregation
void aSubselectAggregation() -
qTableAddEvent
-
aTableAddEvent
void aTableAddEvent() -
qaTableUpdatedEventWKeyBefore
-
qaTableUpdatedEventWKeyAfter
-
qTableDeleteEvent
-
aTableDeleteEvent
void aTableDeleteEvent() -
qAggregationGroupedApplyEnterLeave
void qAggregationGroupedApplyEnterLeave(boolean enter, int numAggregators, int numAccessStates, Object groupKey) -
aAggregationGroupedApplyEnterLeave
void aAggregationGroupedApplyEnterLeave(boolean enter) -
qAggNoAccessEnterLeave
-
aAggNoAccessEnterLeave
-
qAggAccessEnterLeave
-
aAggAccessEnterLeave
void aAggAccessEnterLeave(boolean enter, int index) -
qUpdateIStream
-
aUpdateIStream
-
qUpdateIStreamApply
-
aUpdateIStreamApply
-
qUpdateIStreamApplyWhere
void qUpdateIStreamApplyWhere() -
aUpdateIStreamApplyWhere
-
qUpdateIStreamApplyAssignments
-
aUpdateIStreamApplyAssignments
-
qUpdateIStreamApplyAssignmentItem
void qUpdateIStreamApplyAssignmentItem(int index) -
aUpdateIStreamApplyAssignmentItem
-
qOutputRateConditionScheduledEval
void qOutputRateConditionScheduledEval() -
aOutputRateConditionScheduledEval
void aOutputRateConditionScheduledEval() -
qHistoricalScheduledEval
void qHistoricalScheduledEval() -
aHistoricalScheduledEval
void aHistoricalScheduledEval() -
qJoinExecFilter
void qJoinExecFilter() -
aJoinExecFilter
void aJoinExecFilter(Set<MultiKeyArrayOfKeys<EventBean>> newEvents, Set<MultiKeyArrayOfKeys<EventBean>> oldEvents) -
qJoinCompositionHistorical
void qJoinCompositionHistorical() -
aJoinCompositionHistorical
void aJoinCompositionHistorical(Set<MultiKeyArrayOfKeys<EventBean>> newResults, Set<MultiKeyArrayOfKeys<EventBean>> oldResults) -
qOutputProcessNonBuffered
-
aOutputProcessNonBuffered
void aOutputProcessNonBuffered() -
qOutputProcessNonBufferedJoin
void qOutputProcessNonBufferedJoin(Set<MultiKeyArrayOfKeys<EventBean>> newEvents, Set<MultiKeyArrayOfKeys<EventBean>> oldEvents) -
aOutputProcessNonBufferedJoin
void aOutputProcessNonBufferedJoin()
-