com.espertech.esper.runtime.internal.metrics.stmtmetrics

Class MetricReportingServiceImpl

java.lang.Object

com.espertech.esper.runtime.internal.metrics.stmtmetrics.MetricReportingServiceImpl

All Implemented Interfaces:

com.espertech.esper.common.internal.metrics.stmtmetrics.MetricEventRouter, com.espertech.esper.common.internal.metrics.stmtmetrics.MetricReportingService, DeploymentStateListener, MetricReportingServiceSPI

public class MetricReportingServiceImpl
extends Object
implements MetricReportingServiceSPI, com.espertech.esper.common.internal.metrics.stmtmetrics.MetricEventRouter, DeploymentStateListener

Metrics reporting.

Reports for all statements even if not in a statement group, i.e. statement in default group.

Constructor Summary

Constructors

Constructor and Description
MetricReportingServiceImpl(com.espertech.esper.common.client.configuration.runtime.ConfigurationRuntimeMetricsReporting specification, String runtimeURI) Ctor.

Method Summary

Modifier and Type	Method and Description
void	accountOutput(com.espertech.esper.common.internal.metrics.stmtmetrics.StatementMetricHandle handle, int numIStream, int numRStream, Object epStatement, Object runtime)
void	accountTime(com.espertech.esper.common.internal.metrics.stmtmetrics.StatementMetricHandle metricsHandle, long deltaCPU, long deltaWall, int numInputEvents)
void	addStatementResultListener(MetricsStatementResultListener listener) Add stmt result listener.
void	destroy()
com.espertech.esper.common.internal.metrics.stmtmetrics.StatementMetricHandle	getStatementHandle(int statementId, String deploymentId, String statementName)
CopyOnWriteArraySet<MetricsStatementResultListener>	getStatementOutputHooks() Returns output hooks.
boolean	isMetricsReportingEnabled()
void	onDeployment(DeploymentStateEventDeployed event) Called when a deployment completed
void	onUndeployment(DeploymentStateEventUndeployed event) Called when an undeployment completed
void	processTimeEvent(long timeEventTime)
void	removeStatementResultListener(MetricsStatementResultListener listener) Remove stmt result listener.
void	route(com.espertech.esper.common.client.metric.MetricEvent metricEvent)
void	setContext(com.espertech.esper.common.internal.filtersvc.FilterService filterService, com.espertech.esper.common.internal.schedule.SchedulingService schedulingService, com.espertech.esper.common.internal.event.core.EventServiceSendEventCommon eventServiceSendEventInternal)
void	setMetricsReportingDisabled()
void	setMetricsReportingEnabled()
void	setMetricsReportingInterval(String stmtGroupName, long newInterval)
void	setMetricsReportingStmtDisabled(String deploymentId, String statementName)
void	setMetricsReportingStmtEnabled(String deploymentId, String statementName)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MetricReportingServiceImpl

public MetricReportingServiceImpl(com.espertech.esper.common.client.configuration.runtime.ConfigurationRuntimeMetricsReporting specification,
                                  String runtimeURI)

Ctor.

Parameters:

specification - configuration

runtimeURI - runtime URI

Method Detail

isMetricsReportingEnabled

public boolean isMetricsReportingEnabled()

Specified by:

isMetricsReportingEnabled in interface com.espertech.esper.common.internal.metrics.stmtmetrics.MetricReportingService

addStatementResultListener

public void addStatementResultListener(MetricsStatementResultListener listener)

Description copied from interface: MetricReportingServiceSPI

Add stmt result listener.

Specified by:

addStatementResultListener in interface MetricReportingServiceSPI

Parameters:

listener - to add

removeStatementResultListener

public void removeStatementResultListener(MetricsStatementResultListener listener)

Description copied from interface: MetricReportingServiceSPI

Remove stmt result listener.

Specified by:

removeStatementResultListener in interface MetricReportingServiceSPI

Parameters:

listener - to remove

getStatementOutputHooks

public CopyOnWriteArraySet<MetricsStatementResultListener> getStatementOutputHooks()

Description copied from interface: MetricReportingServiceSPI

Returns output hooks.

Specified by:

getStatementOutputHooks in interface MetricReportingServiceSPI

Returns:

hooks.

setContext

public void setContext(com.espertech.esper.common.internal.filtersvc.FilterService filterService,
                       com.espertech.esper.common.internal.schedule.SchedulingService schedulingService,
                       com.espertech.esper.common.internal.event.core.EventServiceSendEventCommon eventServiceSendEventInternal)

Specified by:

setContext in interface com.espertech.esper.common.internal.metrics.stmtmetrics.MetricReportingService

processTimeEvent

public void processTimeEvent(long timeEventTime)

Specified by:

processTimeEvent in interface com.espertech.esper.common.internal.metrics.stmtmetrics.MetricReportingService

destroy

public void destroy()

Specified by:

destroy in interface com.espertech.esper.common.internal.metrics.stmtmetrics.MetricReportingService

route

public void route(com.espertech.esper.common.client.metric.MetricEvent metricEvent)

Specified by:

route in interface com.espertech.esper.common.internal.metrics.stmtmetrics.MetricEventRouter

accountTime

public void accountTime(com.espertech.esper.common.internal.metrics.stmtmetrics.StatementMetricHandle metricsHandle,
                        long deltaCPU,
                        long deltaWall,
                        int numInputEvents)

Specified by:

accountTime in interface com.espertech.esper.common.internal.metrics.stmtmetrics.MetricReportingService

accountOutput

public void accountOutput(com.espertech.esper.common.internal.metrics.stmtmetrics.StatementMetricHandle handle,
                          int numIStream,
                          int numRStream,
                          Object epStatement,
                          Object runtime)

Specified by:

accountOutput in interface com.espertech.esper.common.internal.metrics.stmtmetrics.MetricReportingService

getStatementHandle

public com.espertech.esper.common.internal.metrics.stmtmetrics.StatementMetricHandle getStatementHandle(int statementId,
                                                                                                        String deploymentId,
                                                                                                        String statementName)

Specified by:

getStatementHandle in interface com.espertech.esper.common.internal.metrics.stmtmetrics.MetricReportingService

onDeployment

public void onDeployment(DeploymentStateEventDeployed event)

Description copied from interface: DeploymentStateListener

Called when a deployment completed

Specified by:

onDeployment in interface DeploymentStateListener

Parameters:

event - deployment information

onUndeployment

public void onUndeployment(DeploymentStateEventUndeployed event)

Description copied from interface: DeploymentStateListener

Called when an undeployment completed

Specified by:

onUndeployment in interface DeploymentStateListener

Parameters:

event - undeployment information

setMetricsReportingInterval

public void setMetricsReportingInterval(String stmtGroupName,
                                        long newInterval)

Specified by:

setMetricsReportingInterval in interface com.espertech.esper.common.internal.metrics.stmtmetrics.MetricReportingService

setMetricsReportingStmtDisabled

public void setMetricsReportingStmtDisabled(String deploymentId,
                                            String statementName)

Specified by:

setMetricsReportingStmtDisabled in interface com.espertech.esper.common.internal.metrics.stmtmetrics.MetricReportingService

setMetricsReportingStmtEnabled

public void setMetricsReportingStmtEnabled(String deploymentId,
                                           String statementName)

Specified by:

setMetricsReportingStmtEnabled in interface com.espertech.esper.common.internal.metrics.stmtmetrics.MetricReportingService

setMetricsReportingEnabled

public void setMetricsReportingEnabled()

Specified by:

setMetricsReportingEnabled in interface com.espertech.esper.common.internal.metrics.stmtmetrics.MetricReportingService

setMetricsReportingDisabled

public void setMetricsReportingDisabled()

Specified by:

setMetricsReportingDisabled in interface com.espertech.esper.common.internal.metrics.stmtmetrics.MetricReportingService