com.espertech.esper.common.internal.metrics.stmtmetrics

Interface MetricReportingService

public interface MetricReportingService

Metrics reporting service for instrumentation data publishing, if enabled.

Method Summary

Modifier and Type	Method and Description
void	accountOutput(StatementMetricHandle handle, int numIStream, int numRStream, Object epStatement, Object runtime) Account for statement output row counting.
void	accountTime(StatementMetricHandle metricsHandle, long deltaCPU, long deltaWall, int numInput) Account for statement CPU and wall time.
void	destroy() Destroy the service.
StatementMetricHandle	getStatementHandle(int statementId, String deploymentId, String statementName) Returns for a new statement a handle for later accounting.
boolean	isMetricsReportingEnabled()
void	processTimeEvent(long currentTime) Indicates current runtime time.
void	setContext(FilterService filterService, SchedulingService schedulingService, EventServiceSendEventCommon eventServiceSendEventInternal)
void	setMetricsReportingDisabled() Disables metrics reporting globally.
void	setMetricsReportingEnabled() Enables metrics reporting globally.
void	setMetricsReportingInterval(String stmtGroupName, long newInterval) Change the reporting interval for the given statement group name.
void	setMetricsReportingStmtDisabled(String deploymentId, String statementName) Disable metrics reporting for statement.
void	setMetricsReportingStmtEnabled(String deploymentId, String statementName) Enable metrics reporting for statement.

Method Detail

setContext

void setContext(FilterService filterService,
                SchedulingService schedulingService,
                EventServiceSendEventCommon eventServiceSendEventInternal)

processTimeEvent

void processTimeEvent(long currentTime)

Indicates current runtime time.

Parameters:

currentTime - runtime time

destroy

void destroy()

Destroy the service.

accountTime

void accountTime(StatementMetricHandle metricsHandle,
                 long deltaCPU,
                 long deltaWall,
                 int numInput)

Account for statement CPU and wall time.

Parameters:

metricsHandle - statement handle

deltaCPU - cpu time nsec

deltaWall - wall time nsec

numInput - number of input rows

accountOutput

void accountOutput(StatementMetricHandle handle,
                   int numIStream,
                   int numRStream,
                   Object epStatement,
                   Object runtime)

Account for statement output row counting.

Parameters:

handle - statement handle

numIStream - number of insert stream rows

numRStream - number of remove stream rows

epStatement - statement

runtime - runtime

getStatementHandle

StatementMetricHandle getStatementHandle(int statementId,
                                         String deploymentId,
                                         String statementName)

Returns for a new statement a handle for later accounting.

Parameters:

statementId - statement id

deploymentId - deployment id

statementName - statement name

Returns:

handle

setMetricsReportingInterval

void setMetricsReportingInterval(String stmtGroupName,
                                 long newInterval)

Change the reporting interval for the given statement group name.

Parameters:

stmtGroupName - group name

newInterval - new interval, or zero or negative value to disable reporting

setMetricsReportingStmtDisabled

void setMetricsReportingStmtDisabled(String deploymentId,
                                     String statementName)

Disable metrics reporting for statement.

Parameters:

deploymentId - deployment id

statementName - statement name

setMetricsReportingStmtEnabled

void setMetricsReportingStmtEnabled(String deploymentId,
                                    String statementName)

Enable metrics reporting for statement.

Parameters:

deploymentId - deployment id

statementName - statement name

setMetricsReportingEnabled

void setMetricsReportingEnabled()

Enables metrics reporting globally.

setMetricsReportingDisabled

void setMetricsReportingDisabled()

Disables metrics reporting globally.

isMetricsReportingEnabled

boolean isMetricsReportingEnabled()