public class InstrumentationDefault extends com.espertech.esper.common.internal.metrics.instrumentation.InstrumentationCommonDefault implements Instrumentation
Modifier and Type | Field and Description |
---|---|
static InstrumentationDefault |
INSTANCE |
Modifier and Type | Method and Description |
---|---|
void |
aAggregationUngroupedApplyEnterLeave(boolean enter) |
boolean |
activated() |
void |
aEvent() |
void |
aEventCP() |
void |
aExprAggValue(Object value) |
void |
aExprAnd(Boolean result) |
void |
aExprArray(Object result) |
void |
aExprBetween(Boolean result) |
void |
aExprBitwise(Object result) |
void |
aExprCase(Object result) |
void |
aExprCast(Object result) |
void |
aExprCoalesce(Object value) |
void |
aExprConcat(String result) |
void |
aExprConst(Object value) |
void |
aExprContextProp(Object result) |
void |
aExprDeclared(Object value) |
void |
aExprDot(Object result) |
void |
aExprDotChain() |
void |
aExprDotChainElement(com.espertech.esper.common.internal.rettype.EPType typeInfo,
Object result) |
void |
aExprEquals(Boolean result) |
void |
aExprEqualsAnyOrAll(Boolean result) |
void |
aExprIdent(Object result) |
void |
aExprIn(Boolean result) |
void |
aExprInstanceof(Boolean result) |
void |
aExprIs(boolean result) |
void |
aExprIStream(boolean newData) |
void |
aExprLike(Boolean result) |
void |
aExprMath(Object result) |
void |
aExprMinMaxRow(Object result) |
void |
aExprNew(Map<String,Object> props) |
void |
aExprNot(Boolean result) |
void |
aExprOr(Boolean result) |
void |
aExprPlugInSingleRow(Object result) |
void |
aExprPrev(Object result) |
void |
aExprPrior(Object result) |
void |
aExprPropExists(boolean exists) |
void |
aExprRegexp(Boolean result) |
void |
aExprRelOp(Boolean result) |
void |
aExprRelOpAnyOrAll(Boolean result) |
void |
aExprStreamUnd(Object result) |
void |
aExprStreamUndMethod(Object result) |
void |
aExprStreamUndSelectClause(com.espertech.esper.common.client.EventBean event) |
void |
aExprSubselect(Object result) |
void |
aExprTableSubpropAccessor(Object result) |
void |
aExprTableSubproperty(Object result) |
void |
aExprTableTop(Object result) |
void |
aExprTimePeriod(Object result) |
void |
aExprTimestamp(long value) |
void |
aExprTypeof(String typeName) |
void |
aExprVariable(Object value) |
void |
aFilter(Collection<com.espertech.esper.common.internal.filtersvc.FilterHandle> matches) |
void |
aFilterActivationStream(com.espertech.esper.common.internal.context.util.AgentInstanceContext agentInstanceContext,
boolean subselect,
int subselectNumber) |
void |
aFilterAdd() |
void |
aFilterBoolean() |
void |
aFilterBooleanExpr(boolean result) |
void |
aFilterHandleSetIndexes() |
void |
aFilterRemove() |
void |
aFilterReverseIndex(Boolean match) |
void |
aHavingClause(Boolean pass) |
void |
aInfraUpdate(com.espertech.esper.common.client.EventBean afterUpdate) |
void |
aInfraUpdateRHSExpr(Object result) |
void |
aNamedWindowCPMulti() |
void |
aNamedWindowCPSingle() |
void |
aNamedWindowDispatch() |
void |
aOrderBy(Object values) |
void |
aOutputProcessNonBuffered() |
void |
aOutputProcessNonBufferedJoin() |
void |
aRegEx(com.espertech.esper.common.internal.epl.rowrecog.state.RowRecogPartitionState partitionState,
List<com.espertech.esper.common.internal.epl.rowrecog.nfa.RowRecogNFAStateEntry> endStates,
List<com.espertech.esper.common.internal.epl.rowrecog.nfa.RowRecogNFAStateEntry> terminationStates) |
void |
aRegExPartition(boolean exists,
Object partitionKey,
com.espertech.esper.common.internal.epl.rowrecog.state.RowRecogPartitionState state) |
void |
aRegExScheduledEval() |
void |
aRegExState(List<com.espertech.esper.common.internal.epl.rowrecog.nfa.RowRecogNFAStateEntry> next,
LinkedHashMap<String,com.espertech.esper.common.internal.collection.Pair<Integer,Boolean>> variableStreams,
int[] multimatchStreamNumToVariable) |
void |
aRegExStateStart(List<com.espertech.esper.common.internal.epl.rowrecog.nfa.RowRecogNFAStateEntry> nextStates,
LinkedHashMap<String,com.espertech.esper.common.internal.collection.Pair<Integer,Boolean>> variableStreams,
int[] multimatchStreamNumToVariable) |
void |
aRegFilter(Boolean result) |
void |
aRegIntervalState(boolean scheduled) |
void |
aRegIntervalValue(long result) |
void |
aRegMeasure(com.espertech.esper.common.client.EventBean outBean) |
void |
aRegOut() |
void |
aResultSetProcessComputeGroupKeys(boolean enter,
Object groupKeysPerEvent) |
void |
aResultSetProcessGroupedRowPerEvent(com.espertech.esper.common.internal.collection.UniformPair<com.espertech.esper.common.client.EventBean[]> pair) |
void |
aResultSetProcessGroupedRowPerGroup(com.espertech.esper.common.internal.collection.UniformPair<com.espertech.esper.common.client.EventBean[]> pair) |
void |
aResultSetProcessSimple(com.espertech.esper.common.internal.collection.UniformPair<com.espertech.esper.common.client.EventBean[]> pair) |
void |
aResultSetProcessUngroupedFullyAgg(com.espertech.esper.common.internal.collection.UniformPair<com.espertech.esper.common.client.EventBean[]> pair) |
void |
aResultSetProcessUngroupedNonfullyAgg(com.espertech.esper.common.internal.collection.UniformPair<com.espertech.esper.common.client.EventBean[]> pair) |
void |
aRouteBetweenStmt() |
void |
aScheduleAdd() |
void |
aScheduleEval(Collection<com.espertech.esper.common.internal.schedule.ScheduleHandle> handles) |
void |
aScheduleRemove() |
void |
aSelectClause(boolean newData,
com.espertech.esper.common.client.EventBean event,
Object[] subscriberParameters) |
void |
aStatementResultExecute() |
void |
aStimulantEvent() |
void |
aStimulantTime() |
void |
aTime() |
void |
aTimeCP() |
void |
qaFilterHandleSetCallbacks(Set<com.espertech.esper.common.internal.filtersvc.FilterHandle> callbackSet) |
void |
qAggregationUngroupedApplyEnterLeave(boolean enter,
int numAggregators,
int numAccessStates) |
void |
qaRuntimeManagementStmtStarted(String runtimeURI,
String deploymentId,
int statementId,
String statementName,
String epl,
long runtimeTime) |
void |
qaRuntimeManagementStmtStop(String runtimeURI,
String deploymentId,
int statementId,
String statementName,
String epl,
long runtimeTime) |
void |
qEvent(com.espertech.esper.common.client.EventBean eventBean,
String runtimeURI,
boolean providedBySendEvent) |
void |
qEventCP(com.espertech.esper.common.client.EventBean theEvent,
com.espertech.esper.common.internal.context.util.EPStatementAgentInstanceHandle handle,
long runtimeTime) |
void |
qExprAggValue(String text) |
void |
qExprAnd(String text) |
void |
qExprArray(String text) |
void |
qExprBetween(String text) |
void |
qExprBitwise(String text,
com.espertech.esper.common.internal.type.BitWiseOpEnum bitWiseOpEnum) |
void |
qExprCase(String text) |
void |
qExprCast(String text) |
void |
qExprCoalesce(String text) |
void |
qExprConcat(String text) |
void |
qExprConst() |
void |
qExprContextProp(String text) |
void |
qExprDeclared(String text,
String name,
String expressionText,
String[] parameterNames) |
void |
qExprDot(String text) |
void |
qExprDotChain(com.espertech.esper.common.internal.rettype.EPType targetTypeInfo,
Object target,
int numUnpacking) |
void |
qExprDotChainElement(int num,
String methodType,
String methodName) |
void |
qExprEquals(String text) |
void |
qExprEqualsAnyOrAll(String text) |
void |
qExprIdent(String fullUnresolvedName) |
void |
qExprIn(String text) |
void |
qExprInstanceof(String text) |
void |
qExprIs(String text) |
void |
qExprIStream(String text) |
void |
qExprLike(String text) |
void |
qExprMath(String text,
String op) |
void |
qExprMinMaxRow(String text) |
void |
qExprNew(String text) |
void |
qExprNot(String text) |
void |
qExprOr(String text) |
void |
qExprPlugInSingleRow(String text,
String declaringClass,
String methodName,
String returnTypeName,
String[] parameterTypes) |
void |
qExprPrev(String text,
boolean newData) |
void |
qExprPrior(String text) |
void |
qExprPropExists(String text) |
void |
qExprRegexp(String text) |
void |
qExprRelOp(String text,
String op) |
void |
qExprRelOpAnyOrAll(String text,
String op) |
void |
qExprStreamUnd(String text) |
void |
qExprStreamUndMethod(String text) |
void |
qExprStreamUndSelectClause(String text) |
void |
qExprSubselect(String text) |
void |
qExprTableSubpropAccessor(String text,
String tableName,
String subpropName,
String aggregationExpression) |
void |
qExprTableSubproperty(String text,
String tableName,
String subpropName) |
void |
qExprTableTop(String text,
String tableName) |
void |
qExprTimePeriod(String text) |
void |
qExprTimestamp(String text) |
void |
qExprTypeof(String text) |
void |
qExprVariable(String text) |
void |
qFilter(com.espertech.esper.common.client.EventBean theEvent) |
void |
qFilterActivationStream(String eventTypeName,
int streamNumber,
com.espertech.esper.common.internal.context.util.AgentInstanceContext agentInstanceContext,
boolean subselect,
int subselectNumber) |
void |
qFilterAdd(com.espertech.esper.common.client.EventType eventType,
com.espertech.esper.common.internal.filterspec.FilterValueSetParam[][] parameters,
com.espertech.esper.common.internal.filtersvc.FilterHandle filterCallback) |
void |
qFilterBoolean(FilterParamIndexBooleanExpr filterParamIndexBooleanExpr) |
void |
qFilterBooleanExpr(int num,
Map.Entry<com.espertech.esper.common.internal.filterspec.ExprNodeAdapterBase,EventEvaluator> evals) |
void |
qFilterHandleSetIndexes(List<FilterParamIndexBase> indizes) |
void |
qFilterRemove(com.espertech.esper.common.internal.filtersvc.FilterHandle filterCallback,
com.espertech.esper.common.client.EventType eventType,
com.espertech.esper.common.internal.filterspec.FilterValueSetParam[][] parameters) |
void |
qFilterReverseIndex(FilterParamIndexBase filterParamIndex,
Object propertyValue) |
void |
qHavingClause(com.espertech.esper.common.client.EventBean[] eventsPerStream) |
void |
qInfraUpdate(com.espertech.esper.common.client.EventBean beforeUpdate,
com.espertech.esper.common.client.EventBean[] eventsPerStream,
int length,
boolean copy) |
void |
qInfraUpdateRHSExpr(int index) |
void |
qNamedWindowCPMulti(String runtimeURI,
Map<com.espertech.esper.common.internal.epl.namedwindow.consume.NamedWindowConsumerView,com.espertech.esper.common.internal.epl.namedwindow.consume.NamedWindowDeltaData> deltaPerConsumer,
com.espertech.esper.common.internal.context.util.EPStatementAgentInstanceHandle handle,
long time) |
void |
qNamedWindowCPSingle(String runtimeURI,
int numConsumers,
com.espertech.esper.common.client.EventBean[] newData,
com.espertech.esper.common.client.EventBean[] oldData,
com.espertech.esper.common.internal.context.util.EPStatementAgentInstanceHandle handle,
long time) |
void |
qNamedWindowDispatch(String runtimeURI) |
void |
qOrderBy(com.espertech.esper.common.client.EventBean[] events,
String[] expressions,
boolean[] descending) |
void |
qOutputProcessNonBuffered(com.espertech.esper.common.client.EventBean[] newData,
com.espertech.esper.common.client.EventBean[] oldData) |
void |
qOutputProcessNonBufferedJoin(Set<com.espertech.esper.common.internal.collection.MultiKey<com.espertech.esper.common.client.EventBean>> newEvents,
Set<com.espertech.esper.common.internal.collection.MultiKey<com.espertech.esper.common.client.EventBean>> oldEvents) |
void |
qRegEx(com.espertech.esper.common.client.EventBean newEvent,
com.espertech.esper.common.internal.epl.rowrecog.state.RowRecogPartitionState partitionState) |
void |
qRegExPartition(com.espertech.esper.common.client.EventBean theEvent) |
void |
qRegExScheduledEval() |
void |
qRegExState(com.espertech.esper.common.internal.epl.rowrecog.nfa.RowRecogNFAStateEntry currentState,
LinkedHashMap<String,com.espertech.esper.common.internal.collection.Pair<Integer,Boolean>> variableStreams,
int[] multimatchStreamNumToVariable) |
void |
qRegExStateStart(com.espertech.esper.common.internal.epl.rowrecog.nfa.RowRecogNFAState startState,
LinkedHashMap<String,com.espertech.esper.common.internal.collection.Pair<Integer,Boolean>> variableStreams,
int[] multimatchStreamNumToVariable) |
void |
qRegFilter(com.espertech.esper.common.client.EventBean[] eventsPerStream) |
void |
qRegIntervalState(com.espertech.esper.common.internal.epl.rowrecog.nfa.RowRecogNFAStateEntry endState,
LinkedHashMap<String,com.espertech.esper.common.internal.collection.Pair<Integer,Boolean>> variableStreams,
int[] multimatchStreamNumToVariable,
long runtimeTime) |
void |
qRegIntervalValue() |
void |
qRegMeasure(com.espertech.esper.common.internal.epl.rowrecog.nfa.RowRecogNFAStateEntry endState,
LinkedHashMap<String,com.espertech.esper.common.internal.collection.Pair<Integer,Boolean>> variableStreams,
int[] multimatchStreamNumToVariable) |
void |
qRegOut(com.espertech.esper.common.client.EventBean[] outBeans) |
void |
qResultSetProcessComputeGroupKeys(boolean enter,
String[] groupKeyNodeExpressions,
com.espertech.esper.common.client.EventBean[] eventsPerStream) |
void |
qResultSetProcessGroupedRowPerEvent() |
void |
qResultSetProcessGroupedRowPerGroup() |
void |
qResultSetProcessSimple() |
void |
qResultSetProcessUngroupedFullyAgg() |
void |
qResultSetProcessUngroupedNonfullyAgg() |
void |
qRouteBetweenStmt(com.espertech.esper.common.client.EventBean theEvent,
com.espertech.esper.common.internal.context.util.EPStatementHandle epStatementHandle,
boolean addToFront) |
void |
qScheduleAdd(long currentTime,
long afterMSec,
com.espertech.esper.common.internal.schedule.ScheduleHandle handle,
long slot) |
void |
qScheduleEval(long currentTime) |
void |
qScheduleRemove(com.espertech.esper.common.internal.schedule.ScheduleHandle handle,
long slot) |
void |
qSelectClause(com.espertech.esper.common.client.EventBean[] eventsPerStream,
boolean newData,
boolean synthesize,
com.espertech.esper.common.internal.epl.expression.core.ExprEvaluatorContext exprEvaluatorContext) |
void |
qStatementResultExecute(com.espertech.esper.common.internal.collection.UniformPair<com.espertech.esper.common.client.EventBean[]> events,
String deploymentId,
int statementId,
String statementName,
long threadId) |
void |
qStimulantEvent(com.espertech.esper.common.client.EventBean eventBean,
String runtimeURI) |
void |
qStimulantTime(long currentTime,
long target,
long ultimateTarget,
boolean span,
Long resolution,
String runtimeURI) |
void |
qTime(long runtimeTime,
String runtimeURI) |
void |
qTimeCP(com.espertech.esper.common.internal.context.util.EPStatementAgentInstanceHandle handle,
long runtimeTime) |
aAggAccessEnterLeave, aAggNoAccessEnterLeave, aAggregationGroupedApplyEnterLeave, aContextPartitionAllocate, aContextPartitionDestroy, aContextScheduledEval, aHistoricalScheduledEval, aIndexAdd, aIndexAddRemove, aIndexJoinLookup, aIndexRemove, aIndexSubordLookup, aInfraMergeWhenThenActionItem, aInfraMergeWhenThenActions, aInfraMergeWhenThenItem, aInfraMergeWhenThens, aInfraOnAction, aInfraTriggeredLookup, aJoinCompositionHistorical, aJoinCompositionQueryStrategy, aJoinCompositionStepUpdIndex, aJoinCompositionStreamToWin, aJoinCompositionWinToWin, aJoinDispatch, aJoinExecFilter, aJoinExecProcess, aJoinExecStrategy, aOutputProcessWCondition, aOutputProcessWConditionJoin, aOutputRateConditionOutputNow, aOutputRateConditionScheduledEval, aOutputRateConditionUpdate, aPatternAndEvaluateFalse, aPatternAndEvaluateTrue, aPatternAndQuit, aPatternAndStart, aPatternEveryDistinctEvalFalse, aPatternEveryDistinctEvaluateTrue, aPatternEveryDistinctQuit, aPatternEveryDistinctStart, aPatternEveryEvalFalse, aPatternEveryEvaluateTrue, aPatternEveryQuit, aPatternEveryStart, aPatternFilterMatch, aPatternFilterQuit, aPatternFilterStart, aPatternFollowedByEvalFalse, aPatternFollowedByEvaluateTrue, aPatternFollowedByQuit, aPatternFollowedByStart, aPatternGuardEvalFalse, aPatternGuardEvaluateTrue, aPatternGuardGuardQuit, aPatternGuardQuit, aPatternGuardScheduledEval, aPatternGuardStart, aPatternMatchUntilEvalFalse, aPatternMatchUntilEvaluateTrue, aPatternMatchUntilQuit, aPatternMatchUntilStart, aPatternNotEvalFalse, aPatternNotEvaluateTrue, aPatternNotQuit, aPatternNotStart, aPatternObserverEvaluateTrue, aPatternObserverQuit, aPatternObserverScheduledEval, aPatternObserverStart, aPatternOrEvalFalse, aPatternOrEvaluateTrue, aPatternOrQuit, aPatternOrStart, aPatternRootEvalFalse, aPatternRootEvaluateTrue, aPatternRootQuit, aPatternRootStart, aSplitStream, aSplitStreamRoute, aSplitStreamWhere, aSubselectAggregation, aTableAddEvent, aTableDeleteEvent, aTableUpdatedEvent, aUpdateIStream, aUpdateIStreamApply, aUpdateIStreamApplyAssignmentItem, aUpdateIStreamApplyAssignments, aUpdateIStreamApplyWhere, aViewIndicate, aViewProcessIRStream, aViewScheduledEval, aWhereClauseFilter, aWhereClauseFilterEval, aWhereClauseIR, qAggAccessEnterLeave, qAggNoAccessEnterLeave, qAggregationGroupedApplyEnterLeave, qaTableUpdatedEventWKeyAfter, qaTableUpdatedEventWKeyBefore, qContextPartitionAllocate, qContextPartitionDestroy, qContextScheduledEval, qHistoricalScheduledEval, qIndexAdd, qIndexAddRemove, qIndexJoinLookup, qIndexRemove, qIndexSubordLookup, qInfraMergeWhenThenActionItem, qInfraMergeWhenThenActions, qInfraMergeWhenThenItem, qInfraMergeWhenThens, qInfraOnAction, qInfraTriggeredLookup, qJoinCompositionHistorical, qJoinCompositionQueryStrategy, qJoinCompositionStepUpdIndex, qJoinCompositionStreamToWin, qJoinCompositionWinToWin, qJoinDispatch, qJoinExecFilter, qJoinExecProcess, qJoinExecStrategy, qOutputProcessWCondition, qOutputProcessWConditionJoin, qOutputRateConditionOutputNow, qOutputRateConditionScheduledEval, qOutputRateConditionUpdate, qPatternAndEvaluateFalse, qPatternAndEvaluateTrue, qPatternAndQuit, qPatternAndStart, qPatternEveryDistinctEvalFalse, qPatternEveryDistinctEvaluateTrue, qPatternEveryDistinctQuit, qPatternEveryDistinctStart, qPatternEveryEvalFalse, qPatternEveryEvaluateTrue, qPatternEveryQuit, qPatternEveryStart, qPatternFilterMatch, qPatternFilterQuit, qPatternFilterStart, qPatternFollowedByEvalFalse, qPatternFollowedByEvaluateTrue, qPatternFollowedByQuit, qPatternFollowedByStart, qPatternGuardEvalFalse, qPatternGuardEvaluateTrue, qPatternGuardGuardQuit, qPatternGuardQuit, qPatternGuardScheduledEval, qPatternGuardStart, qPatternMatchUntilEvalFalse, qPatternMatchUntilEvaluateTrue, qPatternMatchUntilQuit, qPatternMatchUntilStart, qPatternNotEvalFalse, qPatternNotEvaluateTrue, qPatternNotQuit, qPatternNotStart, qPatternObserverEvaluateTrue, qPatternObserverQuit, qPatternObserverScheduledEval, qPatternObserverScheduledEval, qPatternObserverStart, qPatternOrEvalFalse, qPatternOrEvaluateTrue, qPatternOrQuit, qPatternOrStart, qPatternRootEvalFalse, qPatternRootEvaluateTrue, qPatternRootQuit, qPatternRootStart, qRegFilter, qSplitStream, qSplitStreamRoute, qSplitStreamWhere, qSubselectAggregation, qTableAddEvent, qTableDeleteEvent, qTableUpdatedEvent, qUpdateIStream, qUpdateIStreamApply, qUpdateIStreamApplyAssignmentItem, qUpdateIStreamApplyAssignments, qUpdateIStreamApplyWhere, qViewIndicate, qViewProcessIRStream, qViewScheduledEval, qWhereClauseFilter, qWhereClauseFilterEval, qWhereClauseIR
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
aAggAccessEnterLeave, aAggNoAccessEnterLeave, aAggregationGroupedApplyEnterLeave, aContextPartitionAllocate, aContextPartitionDestroy, aContextScheduledEval, aHistoricalScheduledEval, aIndexAdd, aIndexAddRemove, aIndexJoinLookup, aIndexRemove, aIndexSubordLookup, aInfraMergeWhenThenActionItem, aInfraMergeWhenThenActions, aInfraMergeWhenThenItem, aInfraMergeWhenThens, aInfraOnAction, aInfraTriggeredLookup, aJoinCompositionHistorical, aJoinCompositionQueryStrategy, aJoinCompositionStepUpdIndex, aJoinCompositionStreamToWin, aJoinCompositionWinToWin, aJoinDispatch, aJoinExecFilter, aJoinExecProcess, aJoinExecStrategy, aOutputProcessWCondition, aOutputProcessWConditionJoin, aOutputRateConditionOutputNow, aOutputRateConditionScheduledEval, aOutputRateConditionUpdate, aPatternAndEvaluateFalse, aPatternAndEvaluateTrue, aPatternAndQuit, aPatternAndStart, aPatternEveryDistinctEvalFalse, aPatternEveryDistinctEvaluateTrue, aPatternEveryDistinctQuit, aPatternEveryDistinctStart, aPatternEveryEvalFalse, aPatternEveryEvaluateTrue, aPatternEveryQuit, aPatternEveryStart, aPatternFilterMatch, aPatternFilterQuit, aPatternFilterStart, aPatternFollowedByEvalFalse, aPatternFollowedByEvaluateTrue, aPatternFollowedByQuit, aPatternFollowedByStart, aPatternGuardEvalFalse, aPatternGuardEvaluateTrue, aPatternGuardGuardQuit, aPatternGuardQuit, aPatternGuardScheduledEval, aPatternGuardStart, aPatternMatchUntilEvalFalse, aPatternMatchUntilEvaluateTrue, aPatternMatchUntilQuit, aPatternMatchUntilStart, aPatternNotEvalFalse, aPatternNotEvaluateTrue, aPatternNotQuit, aPatternNotStart, aPatternObserverEvaluateTrue, aPatternObserverQuit, aPatternObserverScheduledEval, aPatternObserverStart, aPatternOrEvalFalse, aPatternOrEvaluateTrue, aPatternOrQuit, aPatternOrStart, aPatternRootEvalFalse, aPatternRootEvaluateTrue, aPatternRootQuit, aPatternRootStart, aSplitStream, aSplitStreamRoute, aSplitStreamWhere, aSubselectAggregation, aTableAddEvent, aTableDeleteEvent, aTableUpdatedEvent, aUpdateIStream, aUpdateIStreamApply, aUpdateIStreamApplyAssignmentItem, aUpdateIStreamApplyAssignments, aUpdateIStreamApplyWhere, aViewIndicate, aViewProcessIRStream, aViewScheduledEval, aWhereClauseFilter, aWhereClauseFilterEval, aWhereClauseIR, qAggAccessEnterLeave, qAggNoAccessEnterLeave, qAggregationGroupedApplyEnterLeave, qaTableUpdatedEventWKeyAfter, qaTableUpdatedEventWKeyBefore, qContextPartitionAllocate, qContextPartitionDestroy, qContextScheduledEval, qHistoricalScheduledEval, qIndexAdd, qIndexAddRemove, qIndexJoinLookup, qIndexRemove, qIndexSubordLookup, qInfraMergeWhenThenActionItem, qInfraMergeWhenThenActions, qInfraMergeWhenThenItem, qInfraMergeWhenThens, qInfraOnAction, qInfraTriggeredLookup, qJoinCompositionHistorical, qJoinCompositionQueryStrategy, qJoinCompositionStepUpdIndex, qJoinCompositionStreamToWin, qJoinCompositionWinToWin, qJoinDispatch, qJoinExecFilter, qJoinExecProcess, qJoinExecStrategy, qOutputProcessWCondition, qOutputProcessWConditionJoin, qOutputRateConditionOutputNow, qOutputRateConditionScheduledEval, qOutputRateConditionUpdate, qPatternAndEvaluateFalse, qPatternAndEvaluateTrue, qPatternAndQuit, qPatternAndStart, qPatternEveryDistinctEvalFalse, qPatternEveryDistinctEvaluateTrue, qPatternEveryDistinctQuit, qPatternEveryDistinctStart, qPatternEveryEvalFalse, qPatternEveryEvaluateTrue, qPatternEveryQuit, qPatternEveryStart, qPatternFilterMatch, qPatternFilterQuit, qPatternFilterStart, qPatternFollowedByEvalFalse, qPatternFollowedByEvaluateTrue, qPatternFollowedByQuit, qPatternFollowedByStart, qPatternGuardEvalFalse, qPatternGuardEvaluateTrue, qPatternGuardGuardQuit, qPatternGuardQuit, qPatternGuardScheduledEval, qPatternGuardStart, qPatternMatchUntilEvalFalse, qPatternMatchUntilEvaluateTrue, qPatternMatchUntilQuit, qPatternMatchUntilStart, qPatternNotEvalFalse, qPatternNotEvaluateTrue, qPatternNotQuit, qPatternNotStart, qPatternObserverEvaluateTrue, qPatternObserverQuit, qPatternObserverScheduledEval, qPatternObserverStart, qPatternOrEvalFalse, qPatternOrEvaluateTrue, qPatternOrQuit, qPatternOrStart, qPatternRootEvalFalse, qPatternRootEvaluateTrue, qPatternRootQuit, qPatternRootStart, qRegFilter, qSplitStream, qSplitStreamRoute, qSplitStreamWhere, qSubselectAggregation, qTableAddEvent, qTableDeleteEvent, qTableUpdatedEvent, qUpdateIStream, qUpdateIStreamApply, qUpdateIStreamApplyAssignmentItem, qUpdateIStreamApplyAssignments, qUpdateIStreamApplyWhere, qViewIndicate, qViewProcessIRStream, qViewScheduledEval, qWhereClauseFilter, qWhereClauseFilterEval, qWhereClauseIR
public static final InstrumentationDefault INSTANCE
public boolean activated()
activated
in interface com.espertech.esper.common.internal.metrics.instrumentation.InstrumentationCommon
activated
in class com.espertech.esper.common.internal.metrics.instrumentation.InstrumentationCommonDefault
public void qFilterActivationStream(String eventTypeName, int streamNumber, com.espertech.esper.common.internal.context.util.AgentInstanceContext agentInstanceContext, boolean subselect, int subselectNumber)
qFilterActivationStream
in interface com.espertech.esper.common.internal.metrics.instrumentation.InstrumentationCommon
qFilterActivationStream
in class com.espertech.esper.common.internal.metrics.instrumentation.InstrumentationCommonDefault
public void aFilterActivationStream(com.espertech.esper.common.internal.context.util.AgentInstanceContext agentInstanceContext, boolean subselect, int subselectNumber)
aFilterActivationStream
in interface com.espertech.esper.common.internal.metrics.instrumentation.InstrumentationCommon
aFilterActivationStream
in class com.espertech.esper.common.internal.metrics.instrumentation.InstrumentationCommonDefault
public void qStimulantEvent(com.espertech.esper.common.client.EventBean eventBean, String runtimeURI)
qStimulantEvent
in interface Instrumentation
public void aStimulantEvent()
aStimulantEvent
in interface Instrumentation
public void qStimulantTime(long currentTime, long target, long ultimateTarget, boolean span, Long resolution, String runtimeURI)
qStimulantTime
in interface Instrumentation
public void aStimulantTime()
aStimulantTime
in interface Instrumentation
public void qEvent(com.espertech.esper.common.client.EventBean eventBean, String runtimeURI, boolean providedBySendEvent)
qEvent
in interface Instrumentation
public void aEvent()
aEvent
in interface Instrumentation
public void qEventCP(com.espertech.esper.common.client.EventBean theEvent, com.espertech.esper.common.internal.context.util.EPStatementAgentInstanceHandle handle, long runtimeTime)
qEventCP
in interface Instrumentation
public void aEventCP()
aEventCP
in interface Instrumentation
public void qTime(long runtimeTime, String runtimeURI)
qTime
in interface Instrumentation
public void aTime()
aTime
in interface Instrumentation
public void qTimeCP(com.espertech.esper.common.internal.context.util.EPStatementAgentInstanceHandle handle, long runtimeTime)
qTimeCP
in interface Instrumentation
public void aTimeCP()
aTimeCP
in interface Instrumentation
public void qNamedWindowDispatch(String runtimeURI)
qNamedWindowDispatch
in interface com.espertech.esper.common.internal.metrics.instrumentation.InstrumentationCommon
qNamedWindowDispatch
in class com.espertech.esper.common.internal.metrics.instrumentation.InstrumentationCommonDefault
public void aNamedWindowDispatch()
aNamedWindowDispatch
in interface com.espertech.esper.common.internal.metrics.instrumentation.InstrumentationCommon
aNamedWindowDispatch
in class com.espertech.esper.common.internal.metrics.instrumentation.InstrumentationCommonDefault
public void qNamedWindowCPSingle(String runtimeURI, int numConsumers, com.espertech.esper.common.client.EventBean[] newData, com.espertech.esper.common.client.EventBean[] oldData, com.espertech.esper.common.internal.context.util.EPStatementAgentInstanceHandle handle, long time)
qNamedWindowCPSingle
in interface com.espertech.esper.common.internal.metrics.instrumentation.InstrumentationCommon
qNamedWindowCPSingle
in class com.espertech.esper.common.internal.metrics.instrumentation.InstrumentationCommonDefault
public void aNamedWindowCPSingle()
aNamedWindowCPSingle
in interface com.espertech.esper.common.internal.metrics.instrumentation.InstrumentationCommon
aNamedWindowCPSingle
in class com.espertech.esper.common.internal.metrics.instrumentation.InstrumentationCommonDefault
public void qNamedWindowCPMulti(String runtimeURI, Map<com.espertech.esper.common.internal.epl.namedwindow.consume.NamedWindowConsumerView,com.espertech.esper.common.internal.epl.namedwindow.consume.NamedWindowDeltaData> deltaPerConsumer, com.espertech.esper.common.internal.context.util.EPStatementAgentInstanceHandle handle, long time)
qNamedWindowCPMulti
in interface com.espertech.esper.common.internal.metrics.instrumentation.InstrumentationCommon
qNamedWindowCPMulti
in class com.espertech.esper.common.internal.metrics.instrumentation.InstrumentationCommonDefault
public void aNamedWindowCPMulti()
aNamedWindowCPMulti
in interface com.espertech.esper.common.internal.metrics.instrumentation.InstrumentationCommon
aNamedWindowCPMulti
in class com.espertech.esper.common.internal.metrics.instrumentation.InstrumentationCommonDefault
public void qRegEx(com.espertech.esper.common.client.EventBean newEvent, com.espertech.esper.common.internal.epl.rowrecog.state.RowRecogPartitionState partitionState)
qRegEx
in interface com.espertech.esper.common.internal.metrics.instrumentation.InstrumentationCommon
qRegEx
in class com.espertech.esper.common.internal.metrics.instrumentation.InstrumentationCommonDefault
public void aRegEx(com.espertech.esper.common.internal.epl.rowrecog.state.RowRecogPartitionState partitionState, List<com.espertech.esper.common.internal.epl.rowrecog.nfa.RowRecogNFAStateEntry> endStates, List<com.espertech.esper.common.internal.epl.rowrecog.nfa.RowRecogNFAStateEntry> terminationStates)
aRegEx
in interface com.espertech.esper.common.internal.metrics.instrumentation.InstrumentationCommon
aRegEx
in class com.espertech.esper.common.internal.metrics.instrumentation.InstrumentationCommonDefault
public void qRegExState(com.espertech.esper.common.internal.epl.rowrecog.nfa.RowRecogNFAStateEntry currentState, LinkedHashMap<String,com.espertech.esper.common.internal.collection.Pair<Integer,Boolean>> variableStreams, int[] multimatchStreamNumToVariable)
qRegExState
in interface com.espertech.esper.common.internal.metrics.instrumentation.InstrumentationCommon
qRegExState
in class com.espertech.esper.common.internal.metrics.instrumentation.InstrumentationCommonDefault
public void aRegExState(List<com.espertech.esper.common.internal.epl.rowrecog.nfa.RowRecogNFAStateEntry> next, LinkedHashMap<String,com.espertech.esper.common.internal.collection.Pair<Integer,Boolean>> variableStreams, int[] multimatchStreamNumToVariable)
aRegExState
in interface com.espertech.esper.common.internal.metrics.instrumentation.InstrumentationCommon
aRegExState
in class com.espertech.esper.common.internal.metrics.instrumentation.InstrumentationCommonDefault
public void qRegExStateStart(com.espertech.esper.common.internal.epl.rowrecog.nfa.RowRecogNFAState startState, LinkedHashMap<String,com.espertech.esper.common.internal.collection.Pair<Integer,Boolean>> variableStreams, int[] multimatchStreamNumToVariable)
qRegExStateStart
in interface com.espertech.esper.common.internal.metrics.instrumentation.InstrumentationCommon
qRegExStateStart
in class com.espertech.esper.common.internal.metrics.instrumentation.InstrumentationCommonDefault
public void aRegExStateStart(List<com.espertech.esper.common.internal.epl.rowrecog.nfa.RowRecogNFAStateEntry> nextStates, LinkedHashMap<String,com.espertech.esper.common.internal.collection.Pair<Integer,Boolean>> variableStreams, int[] multimatchStreamNumToVariable)
aRegExStateStart
in interface com.espertech.esper.common.internal.metrics.instrumentation.InstrumentationCommon
aRegExStateStart
in class com.espertech.esper.common.internal.metrics.instrumentation.InstrumentationCommonDefault
public void qRegExPartition(com.espertech.esper.common.client.EventBean theEvent)
qRegExPartition
in interface com.espertech.esper.common.internal.metrics.instrumentation.InstrumentationCommon
qRegExPartition
in class com.espertech.esper.common.internal.metrics.instrumentation.InstrumentationCommonDefault
public void aRegExPartition(boolean exists, Object partitionKey, com.espertech.esper.common.internal.epl.rowrecog.state.RowRecogPartitionState state)
aRegExPartition
in interface com.espertech.esper.common.internal.metrics.instrumentation.InstrumentationCommon
aRegExPartition
in class com.espertech.esper.common.internal.metrics.instrumentation.InstrumentationCommonDefault
public void qRegIntervalValue()
qRegIntervalValue
in interface com.espertech.esper.common.internal.metrics.instrumentation.InstrumentationCommon
qRegIntervalValue
in class com.espertech.esper.common.internal.metrics.instrumentation.InstrumentationCommonDefault
public void aRegIntervalValue(long result)
aRegIntervalValue
in interface com.espertech.esper.common.internal.metrics.instrumentation.InstrumentationCommon
aRegIntervalValue
in class com.espertech.esper.common.internal.metrics.instrumentation.InstrumentationCommonDefault
public void qRegIntervalState(com.espertech.esper.common.internal.epl.rowrecog.nfa.RowRecogNFAStateEntry endState, LinkedHashMap<String,com.espertech.esper.common.internal.collection.Pair<Integer,Boolean>> variableStreams, int[] multimatchStreamNumToVariable, long runtimeTime)
qRegIntervalState
in interface com.espertech.esper.common.internal.metrics.instrumentation.InstrumentationCommon
qRegIntervalState
in class com.espertech.esper.common.internal.metrics.instrumentation.InstrumentationCommonDefault
public void aRegIntervalState(boolean scheduled)
aRegIntervalState
in interface com.espertech.esper.common.internal.metrics.instrumentation.InstrumentationCommon
aRegIntervalState
in class com.espertech.esper.common.internal.metrics.instrumentation.InstrumentationCommonDefault
public void qRegOut(com.espertech.esper.common.client.EventBean[] outBeans)
qRegOut
in interface com.espertech.esper.common.internal.metrics.instrumentation.InstrumentationCommon
qRegOut
in class com.espertech.esper.common.internal.metrics.instrumentation.InstrumentationCommonDefault
public void aRegOut()
aRegOut
in interface com.espertech.esper.common.internal.metrics.instrumentation.InstrumentationCommon
aRegOut
in class com.espertech.esper.common.internal.metrics.instrumentation.InstrumentationCommonDefault
public void qRegMeasure(com.espertech.esper.common.internal.epl.rowrecog.nfa.RowRecogNFAStateEntry endState, LinkedHashMap<String,com.espertech.esper.common.internal.collection.Pair<Integer,Boolean>> variableStreams, int[] multimatchStreamNumToVariable)
qRegMeasure
in interface com.espertech.esper.common.internal.metrics.instrumentation.InstrumentationCommon
qRegMeasure
in class com.espertech.esper.common.internal.metrics.instrumentation.InstrumentationCommonDefault
public void aRegMeasure(com.espertech.esper.common.client.EventBean outBean)
aRegMeasure
in interface com.espertech.esper.common.internal.metrics.instrumentation.InstrumentationCommon
aRegMeasure
in class com.espertech.esper.common.internal.metrics.instrumentation.InstrumentationCommonDefault
public void qRegExScheduledEval()
qRegExScheduledEval
in interface com.espertech.esper.common.internal.metrics.instrumentation.InstrumentationCommon
qRegExScheduledEval
in class com.espertech.esper.common.internal.metrics.instrumentation.InstrumentationCommonDefault
public void aRegExScheduledEval()
aRegExScheduledEval
in interface com.espertech.esper.common.internal.metrics.instrumentation.InstrumentationCommon
aRegExScheduledEval
in class com.espertech.esper.common.internal.metrics.instrumentation.InstrumentationCommonDefault
public void qRegFilter(com.espertech.esper.common.client.EventBean[] eventsPerStream)
public void aRegFilter(Boolean result)
aRegFilter
in interface com.espertech.esper.common.internal.metrics.instrumentation.InstrumentationCommon
aRegFilter
in class com.espertech.esper.common.internal.metrics.instrumentation.InstrumentationCommonDefault
public void qExprEquals(String text)
qExprEquals
in interface Instrumentation
public void aExprEquals(Boolean result)
aExprEquals
in interface Instrumentation
public void qOutputProcessNonBuffered(com.espertech.esper.common.client.EventBean[] newData, com.espertech.esper.common.client.EventBean[] oldData)
qOutputProcessNonBuffered
in interface Instrumentation
public void aOutputProcessNonBuffered()
aOutputProcessNonBuffered
in interface Instrumentation
public void qSelectClause(com.espertech.esper.common.client.EventBean[] eventsPerStream, boolean newData, boolean synthesize, com.espertech.esper.common.internal.epl.expression.core.ExprEvaluatorContext exprEvaluatorContext)
qSelectClause
in interface Instrumentation
public void aSelectClause(boolean newData, com.espertech.esper.common.client.EventBean event, Object[] subscriberParameters)
aSelectClause
in interface Instrumentation
public void qExprBitwise(String text, com.espertech.esper.common.internal.type.BitWiseOpEnum bitWiseOpEnum)
qExprBitwise
in interface Instrumentation
public void aExprBitwise(Object result)
aExprBitwise
in interface Instrumentation
public void qExprIdent(String fullUnresolvedName)
qExprIdent
in interface Instrumentation
public void aExprIdent(Object result)
aExprIdent
in interface Instrumentation
public void qExprMath(String text, String op)
qExprMath
in interface Instrumentation
public void aExprMath(Object result)
aExprMath
in interface Instrumentation
public void qExprRegexp(String text)
qExprRegexp
in interface Instrumentation
public void aExprRegexp(Boolean result)
aExprRegexp
in interface Instrumentation
public void qExprTypeof(String text)
qExprTypeof
in interface Instrumentation
public void aExprTypeof(String typeName)
aExprTypeof
in interface Instrumentation
public void qExprOr(String text)
qExprOr
in interface Instrumentation
public void aExprOr(Boolean result)
aExprOr
in interface Instrumentation
public void qExprIn(String text)
qExprIn
in interface Instrumentation
public void aExprIn(Boolean result)
aExprIn
in interface Instrumentation
public void qExprConcat(String text)
qExprConcat
in interface Instrumentation
public void aExprConcat(String result)
aExprConcat
in interface Instrumentation
public void qExprCoalesce(String text)
qExprCoalesce
in interface Instrumentation
public void aExprCoalesce(Object value)
aExprCoalesce
in interface Instrumentation
public void qExprBetween(String text)
qExprBetween
in interface Instrumentation
public void aExprBetween(Boolean result)
aExprBetween
in interface Instrumentation
public void qExprCast(String text)
qExprCast
in interface Instrumentation
public void aExprCast(Object result)
aExprCast
in interface Instrumentation
public void qExprCase(String text)
qExprCase
in interface Instrumentation
public void aExprCase(Object result)
aExprCase
in interface Instrumentation
public void qExprArray(String text)
qExprArray
in interface Instrumentation
public void aExprArray(Object result)
aExprArray
in interface Instrumentation
public void qExprEqualsAnyOrAll(String text)
qExprEqualsAnyOrAll
in interface Instrumentation
public void aExprEqualsAnyOrAll(Boolean result)
aExprEqualsAnyOrAll
in interface Instrumentation
public void qExprPropExists(String text)
qExprPropExists
in interface Instrumentation
public void aExprPropExists(boolean exists)
aExprPropExists
in interface Instrumentation
public void qExprRelOpAnyOrAll(String text, String op)
qExprRelOpAnyOrAll
in interface Instrumentation
public void aExprRelOpAnyOrAll(Boolean result)
aExprRelOpAnyOrAll
in interface Instrumentation
public void qExprIs(String text)
qExprIs
in interface Instrumentation
public void aExprIs(boolean result)
aExprIs
in interface Instrumentation
public void qExprTimestamp(String text)
qExprTimestamp
in interface Instrumentation
public void aExprTimestamp(long value)
aExprTimestamp
in interface Instrumentation
public void qExprInstanceof(String text)
qExprInstanceof
in interface Instrumentation
public void aExprInstanceof(Boolean result)
aExprInstanceof
in interface Instrumentation
public void qExprVariable(String text)
qExprVariable
in interface Instrumentation
public void aExprVariable(Object value)
aExprVariable
in interface Instrumentation
public void qExprStreamUndSelectClause(String text)
qExprStreamUndSelectClause
in interface Instrumentation
public void aExprStreamUndSelectClause(com.espertech.esper.common.client.EventBean event)
aExprStreamUndSelectClause
in interface Instrumentation
public void qExprRelOp(String text, String op)
qExprRelOp
in interface Instrumentation
public void aExprRelOp(Boolean result)
aExprRelOp
in interface Instrumentation
public void qExprMinMaxRow(String text)
qExprMinMaxRow
in interface Instrumentation
public void aExprMinMaxRow(Object result)
aExprMinMaxRow
in interface Instrumentation
public void qExprNew(String text)
qExprNew
in interface Instrumentation
public void aExprNew(Map<String,Object> props)
aExprNew
in interface Instrumentation
public void qExprNot(String text)
qExprNot
in interface Instrumentation
public void aExprNot(Boolean result)
aExprNot
in interface Instrumentation
public void qExprIStream(String text)
qExprIStream
in interface Instrumentation
public void aExprIStream(boolean newData)
aExprIStream
in interface Instrumentation
public void qExprConst()
qExprConst
in interface Instrumentation
public void aExprConst(Object value)
aExprConst
in interface Instrumentation
public void qExprPlugInSingleRow(String text, String declaringClass, String methodName, String returnTypeName, String[] parameterTypes)
qExprPlugInSingleRow
in interface Instrumentation
public void aExprPlugInSingleRow(Object result)
aExprPlugInSingleRow
in interface Instrumentation
public void qExprContextProp(String text)
qExprContextProp
in interface Instrumentation
public void aExprContextProp(Object result)
aExprContextProp
in interface Instrumentation
public void qExprDotChain(com.espertech.esper.common.internal.rettype.EPType targetTypeInfo, Object target, int numUnpacking)
qExprDotChain
in interface Instrumentation
public void aExprDotChain()
aExprDotChain
in interface Instrumentation
public void qExprDot(String text)
qExprDot
in interface Instrumentation
public void aExprDot(Object result)
aExprDot
in interface Instrumentation
public void qExprStreamUndMethod(String text)
qExprStreamUndMethod
in interface Instrumentation
public void aExprStreamUndMethod(Object result)
aExprStreamUndMethod
in interface Instrumentation
public void qExprDotChainElement(int num, String methodType, String methodName)
qExprDotChainElement
in interface Instrumentation
public void aExprDotChainElement(com.espertech.esper.common.internal.rettype.EPType typeInfo, Object result)
aExprDotChainElement
in interface Instrumentation
public void qExprPrev(String text, boolean newData)
qExprPrev
in interface Instrumentation
public void aExprPrev(Object result)
aExprPrev
in interface Instrumentation
public void qExprPrior(String text)
qExprPrior
in interface Instrumentation
public void aExprPrior(Object result)
aExprPrior
in interface Instrumentation
public void qScheduleAdd(long currentTime, long afterMSec, com.espertech.esper.common.internal.schedule.ScheduleHandle handle, long slot)
qScheduleAdd
in interface Instrumentation
public void aScheduleAdd()
aScheduleAdd
in interface Instrumentation
public void qScheduleRemove(com.espertech.esper.common.internal.schedule.ScheduleHandle handle, long slot)
qScheduleRemove
in interface Instrumentation
public void aScheduleRemove()
aScheduleRemove
in interface Instrumentation
public void qFilterRemove(com.espertech.esper.common.internal.filtersvc.FilterHandle filterCallback, com.espertech.esper.common.client.EventType eventType, com.espertech.esper.common.internal.filterspec.FilterValueSetParam[][] parameters)
qFilterRemove
in interface Instrumentation
public void aFilterRemove()
aFilterRemove
in interface Instrumentation
public void qFilterAdd(com.espertech.esper.common.client.EventType eventType, com.espertech.esper.common.internal.filterspec.FilterValueSetParam[][] parameters, com.espertech.esper.common.internal.filtersvc.FilterHandle filterCallback)
qFilterAdd
in interface Instrumentation
public void aFilterAdd()
aFilterAdd
in interface Instrumentation
public void qExprTimePeriod(String text)
public void aExprTimePeriod(Object result)
public void qExprAnd(String text)
qExprAnd
in interface Instrumentation
public void aExprAnd(Boolean result)
aExprAnd
in interface Instrumentation
public void qExprLike(String text)
qExprLike
in interface Instrumentation
public void aExprLike(Boolean result)
aExprLike
in interface Instrumentation
public void qResultSetProcessUngroupedFullyAgg()
qResultSetProcessUngroupedFullyAgg
in interface Instrumentation
public void aResultSetProcessUngroupedFullyAgg(com.espertech.esper.common.internal.collection.UniformPair<com.espertech.esper.common.client.EventBean[]> pair)
aResultSetProcessUngroupedFullyAgg
in interface Instrumentation
public void qAggregationUngroupedApplyEnterLeave(boolean enter, int numAggregators, int numAccessStates)
qAggregationUngroupedApplyEnterLeave
in interface Instrumentation
public void aAggregationUngroupedApplyEnterLeave(boolean enter)
aAggregationUngroupedApplyEnterLeave
in interface Instrumentation
public void qExprAggValue(String text)
qExprAggValue
in interface Instrumentation
public void aExprAggValue(Object value)
aExprAggValue
in interface Instrumentation
public void qOutputProcessNonBufferedJoin(Set<com.espertech.esper.common.internal.collection.MultiKey<com.espertech.esper.common.client.EventBean>> newEvents, Set<com.espertech.esper.common.internal.collection.MultiKey<com.espertech.esper.common.client.EventBean>> oldEvents)
qOutputProcessNonBufferedJoin
in interface Instrumentation
public void aOutputProcessNonBufferedJoin()
aOutputProcessNonBufferedJoin
in interface Instrumentation
public void qResultSetProcessGroupedRowPerGroup()
qResultSetProcessGroupedRowPerGroup
in interface Instrumentation
public void aResultSetProcessGroupedRowPerGroup(com.espertech.esper.common.internal.collection.UniformPair<com.espertech.esper.common.client.EventBean[]> pair)
aResultSetProcessGroupedRowPerGroup
in interface Instrumentation
public void qResultSetProcessComputeGroupKeys(boolean enter, String[] groupKeyNodeExpressions, com.espertech.esper.common.client.EventBean[] eventsPerStream)
qResultSetProcessComputeGroupKeys
in interface Instrumentation
public void aResultSetProcessComputeGroupKeys(boolean enter, Object groupKeysPerEvent)
aResultSetProcessComputeGroupKeys
in interface Instrumentation
public void qResultSetProcessUngroupedNonfullyAgg()
qResultSetProcessUngroupedNonfullyAgg
in interface Instrumentation
public void aResultSetProcessUngroupedNonfullyAgg(com.espertech.esper.common.internal.collection.UniformPair<com.espertech.esper.common.client.EventBean[]> pair)
aResultSetProcessUngroupedNonfullyAgg
in interface Instrumentation
public void qResultSetProcessGroupedRowPerEvent()
qResultSetProcessGroupedRowPerEvent
in interface Instrumentation
public void aResultSetProcessGroupedRowPerEvent(com.espertech.esper.common.internal.collection.UniformPair<com.espertech.esper.common.client.EventBean[]> pair)
aResultSetProcessGroupedRowPerEvent
in interface Instrumentation
public void qResultSetProcessSimple()
qResultSetProcessSimple
in interface Instrumentation
public void aResultSetProcessSimple(com.espertech.esper.common.internal.collection.UniformPair<com.espertech.esper.common.client.EventBean[]> pair)
aResultSetProcessSimple
in interface Instrumentation
public void qFilter(com.espertech.esper.common.client.EventBean theEvent)
qFilter
in interface Instrumentation
public void aFilter(Collection<com.espertech.esper.common.internal.filtersvc.FilterHandle> matches)
aFilter
in interface Instrumentation
public void qFilterHandleSetIndexes(List<FilterParamIndexBase> indizes)
qFilterHandleSetIndexes
in interface Instrumentation
public void aFilterHandleSetIndexes()
aFilterHandleSetIndexes
in interface Instrumentation
public void qFilterReverseIndex(FilterParamIndexBase filterParamIndex, Object propertyValue)
qFilterReverseIndex
in interface Instrumentation
public void aFilterReverseIndex(Boolean match)
aFilterReverseIndex
in interface Instrumentation
public void qFilterBoolean(FilterParamIndexBooleanExpr filterParamIndexBooleanExpr)
qFilterBoolean
in interface Instrumentation
public void aFilterBoolean()
aFilterBoolean
in interface Instrumentation
public void qFilterBooleanExpr(int num, Map.Entry<com.espertech.esper.common.internal.filterspec.ExprNodeAdapterBase,EventEvaluator> evals)
qFilterBooleanExpr
in interface Instrumentation
public void aFilterBooleanExpr(boolean result)
aFilterBooleanExpr
in interface Instrumentation
public void qExprDeclared(String text, String name, String expressionText, String[] parameterNames)
qExprDeclared
in interface Instrumentation
public void aExprDeclared(Object value)
aExprDeclared
in interface Instrumentation
public void qInfraUpdate(com.espertech.esper.common.client.EventBean beforeUpdate, com.espertech.esper.common.client.EventBean[] eventsPerStream, int length, boolean copy)
qInfraUpdate
in interface Instrumentation
public void aInfraUpdate(com.espertech.esper.common.client.EventBean afterUpdate)
aInfraUpdate
in interface Instrumentation
public void qInfraUpdateRHSExpr(int index)
qInfraUpdateRHSExpr
in interface Instrumentation
public void aInfraUpdateRHSExpr(Object result)
aInfraUpdateRHSExpr
in interface Instrumentation
public void qRouteBetweenStmt(com.espertech.esper.common.client.EventBean theEvent, com.espertech.esper.common.internal.context.util.EPStatementHandle epStatementHandle, boolean addToFront)
qRouteBetweenStmt
in interface Instrumentation
public void aRouteBetweenStmt()
aRouteBetweenStmt
in interface Instrumentation
public void qScheduleEval(long currentTime)
qScheduleEval
in interface Instrumentation
public void aScheduleEval(Collection<com.espertech.esper.common.internal.schedule.ScheduleHandle> handles)
aScheduleEval
in interface Instrumentation
public void qStatementResultExecute(com.espertech.esper.common.internal.collection.UniformPair<com.espertech.esper.common.client.EventBean[]> events, String deploymentId, int statementId, String statementName, long threadId)
qStatementResultExecute
in interface Instrumentation
public void aStatementResultExecute()
aStatementResultExecute
in interface Instrumentation
public void qOrderBy(com.espertech.esper.common.client.EventBean[] events, String[] expressions, boolean[] descending)
qOrderBy
in interface Instrumentation
public void aOrderBy(Object values)
aOrderBy
in interface Instrumentation
public void qHavingClause(com.espertech.esper.common.client.EventBean[] eventsPerStream)
qHavingClause
in interface Instrumentation
public void aHavingClause(Boolean pass)
aHavingClause
in interface Instrumentation
public void qExprSubselect(String text)
qExprSubselect
in interface Instrumentation
public void aExprSubselect(Object result)
aExprSubselect
in interface Instrumentation
public void qExprTableSubpropAccessor(String text, String tableName, String subpropName, String aggregationExpression)
qExprTableSubpropAccessor
in interface Instrumentation
public void aExprTableSubpropAccessor(Object result)
aExprTableSubpropAccessor
in interface Instrumentation
public void qExprTableSubproperty(String text, String tableName, String subpropName)
qExprTableSubproperty
in interface Instrumentation
public void aExprTableSubproperty(Object result)
aExprTableSubproperty
in interface Instrumentation
public void qExprTableTop(String text, String tableName)
qExprTableTop
in interface Instrumentation
public void aExprTableTop(Object result)
aExprTableTop
in interface Instrumentation
public void qaRuntimeManagementStmtStarted(String runtimeURI, String deploymentId, int statementId, String statementName, String epl, long runtimeTime)
qaRuntimeManagementStmtStarted
in interface Instrumentation
public void qaRuntimeManagementStmtStop(String runtimeURI, String deploymentId, int statementId, String statementName, String epl, long runtimeTime)
qaRuntimeManagementStmtStop
in interface Instrumentation
public void qExprStreamUnd(String text)
qExprStreamUnd
in interface Instrumentation
public void aExprStreamUnd(Object result)
aExprStreamUnd
in interface Instrumentation
public void qaFilterHandleSetCallbacks(Set<com.espertech.esper.common.internal.filtersvc.FilterHandle> callbackSet)
qaFilterHandleSetCallbacks
in interface Instrumentation
Copyright © 2005–2018. All rights reserved.