com.espertech.esper.epl.metric

Interface MetricReportingService

All Known Subinterfaces:

MetricReportingServiceSPI

All Known Implementing Classes:

MetricReportingServiceImpl

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) 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 statementName) Returns for a new statement a handle for later accounting.
void	processTimeEvent(long currentTime) Indicates current engine time.
void	setContext(EPRuntime runtime, EPServicesContext servicesContext) Sets runtime and services.
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 statementName) Disable metrics reporting for statement.
void	setMetricsReportingStmtEnabled(String statementName) Enable metrics reporting for statement.

Method Detail

setContext

void setContext(EPRuntime runtime,
                EPServicesContext servicesContext)

Sets runtime and services.

Parameters:

runtime - runtime

servicesContext - services

processTimeEvent

void processTimeEvent(long currentTime)

Indicates current engine time.

Parameters:

currentTime - engine 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)

Account for statement output row counting.

Parameters:

handle - statement handle

numIStream - number of insert stream rows

numRStream - number of remove stream rows

getStatementHandle

StatementMetricHandle getStatementHandle(int statementId,
                                         String statementName)

Returns for a new statement a handle for later accounting.

Parameters:

statementId - statement 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 statementName)

Disable metrics reporting for statement.

Parameters:

statementName - statement name

setMetricsReportingStmtEnabled

void setMetricsReportingStmtEnabled(String statementName)

Enable metrics reporting for statement.

Parameters:

statementName - statement name

setMetricsReportingEnabled

void setMetricsReportingEnabled()

Enables metrics reporting globally.

setMetricsReportingDisabled

void setMetricsReportingDisabled()

Disables metrics reporting globally.