com.espertech.esper.epl.metric
Class StatementMetricRepository

java.lang.Object
  com.espertech.esper.epl.metric.StatementMetricRepository

public class StatementMetricRepository
extends java.lang.Object

A repository for all statement metrics that organizes statements into statement groups.

At a minimum there is one group (the default) of index zero.

Constructor Summary

StatementMetricRepository(java.lang.String engineURI, ConfigurationMetricsReporting specification)
Ctor.

Method Summary

void	accountOutput(StatementMetricHandle handle, int numIStream, int numRStream) Account row output.
void	accountTimes(StatementMetricHandle handle, long cpu, long wall, int numInput) Account statement times.
StatementMetricHandle	addStatement(java.lang.String stmtName) Add a statement, inspecting the statement name and adding it to a statement group or the default group, if none.
void	removeStatement(java.lang.String stmtName) Remove statement.
StatementMetric[]	reportGroup(int group) Report for a given statement group.

Methods inherited from class java.lang.Object

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

Constructor Detail

StatementMetricRepository

public StatementMetricRepository(java.lang.String engineURI,
                                 ConfigurationMetricsReporting specification)

Ctor.

Parameters:

engineURI - engine URI

specification - specifies statement groups

Method Detail

addStatement

public StatementMetricHandle addStatement(java.lang.String stmtName)

Add a statement, inspecting the statement name and adding it to a statement group or the default group, if none.

Parameters:

stmtName - name to inspect

Returns:

handle for statement

removeStatement

public void removeStatement(java.lang.String stmtName)

Remove statement.

Parameters:

stmtName - to remove

accountTimes

public void accountTimes(StatementMetricHandle handle,
                         long cpu,
                         long wall,
                         int numInput)

Account statement times.

Parameters:

handle - statement handle

cpu - time

wall - time

accountOutput

public void accountOutput(StatementMetricHandle handle,
                          int numIStream,
                          int numRStream)

Account row output.

Parameters:

handle - statement handle

numIStream - num rows insert stream

numRStream - num rows remove stream

reportGroup

public StatementMetric[] reportGroup(int group)

Report for a given statement group.

Parameters:

group - to report

Returns:

metrics or null if none