Package | Description |
---|---|
com.espertech.esper.common.internal.context.util | |
com.espertech.esper.common.internal.metrics.stmtmetrics |
Services for metrics reporting, including global flag, repositories and threading.
|
Modifier and Type | Method and Description |
---|---|
StatementMetricHandle |
EPStatementHandle.getMetricsHandle()
Returns handle for metrics reporting.
|
Constructor and Description |
---|
EPStatementHandle(String statementName,
String deploymentId,
int statementId,
String optionalStatementEPL,
int priority,
boolean preemptive,
boolean canSelfJoin,
MultiMatchHandler multiMatchHandler,
boolean hasVariables,
boolean hasTableAccess,
StatementMetricHandle metricsHandle,
InsertIntoLatchFactory insertIntoFrontLatchFactory,
InsertIntoLatchFactory insertIntoBackLatchFactory) |
Modifier and Type | Method and Description |
---|---|
StatementMetricHandle |
StatementMetricRepository.addStatement(DeploymentIdNamePair statement)
Add a statement, inspecting the statement name and adding it to a statement group or the default group, if none.
|
StatementMetricHandle |
MetricReportingService.getStatementHandle(int statementId,
String deploymentId,
String statementName)
Returns for a new statement a handle for later accounting.
|
Modifier and Type | Method and Description |
---|---|
void |
StatementMetricRepository.accountOutput(StatementMetricHandle handle,
int numIStream,
int numRStream)
Account row output.
|
void |
MetricReportingService.accountOutput(StatementMetricHandle handle,
int numIStream,
int numRStream,
Object epStatement,
Object runtime)
Account for statement output row counting.
|
void |
MetricReportingService.accountTime(StatementMetricHandle metricsHandle,
long deltaCPU,
long deltaWall,
int numInput)
Account for statement CPU and wall time.
|
void |
StatementMetricRepository.accountTimes(StatementMetricHandle handle,
long cpu,
long wall,
int numInput)
Account statement times.
|
Copyright © 2005–2018. All rights reserved.