Package | Description |
---|---|
com.espertech.esper.core.service |
Implementation of client package interfaces, glue code
|
com.espertech.esper.epl.metric |
Services for metrics reporting, including global flag, repositories and threading.
|
com.espertech.esper.epl.named |
Named window classes are in this package
|
com.espertech.esper.epl.table.onaction |
Table on-action handlers.
|
Modifier and Type | Method and Description |
---|---|
StatementMetricHandle |
EPStatementHandle.getMetricsHandle()
Returns handle for metrics reporting.
|
Modifier and Type | Method and Description |
---|---|
void |
StatementResultServiceImpl.setContext(EPStatementSPI epStatement,
EPServiceProviderSPI epServiceProvider,
boolean isInsertInto,
boolean isPattern,
boolean isDistinct,
boolean isForClause,
StatementMetricHandle statementMetricHandle) |
void |
StatementResultService.setContext(EPStatementSPI epStatement,
EPServiceProviderSPI epServiceProvider,
boolean isInsertInto,
boolean isPattern,
boolean isDistinct,
boolean isForClause,
StatementMetricHandle statementMetricHandle)
For initialization of the service to provide statement context.
|
Constructor and Description |
---|
EPStatementHandle(int statementId,
String statementName,
String statementText,
StatementType statementType,
String expressionText,
boolean hasVariables,
StatementMetricHandle metricsHandle,
int priority,
boolean preemptive,
boolean hasTableAccess,
MultiMatchHandler multiMatchHandler)
Ctor.
|
Modifier and Type | Method and Description |
---|---|
StatementMetricHandle |
StatementMetricRepository.addStatement(String stmtName)
Add a statement, inspecting the statement name and adding it to a statement group or the default group, if none.
|
StatementMetricHandle |
MetricReportingServiceImpl.getStatementHandle(int statementId,
String statementName) |
StatementMetricHandle |
MetricReportingService.getStatementHandle(int statementId,
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 |
MetricReportingServiceImpl.accountOutput(StatementMetricHandle handle,
int numIStream,
int numRStream) |
void |
MetricReportingService.accountOutput(StatementMetricHandle handle,
int numIStream,
int numRStream)
Account for statement output row counting.
|
void |
MetricReportingServiceImpl.accountTime(StatementMetricHandle metricsHandle,
long deltaCPU,
long deltaWall,
int numInputEvents) |
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.
|
Modifier and Type | Method and Description |
---|---|
StatementMetricHandle |
NamedWindowOnMergeViewFactory.getCreateNamedWindowMetricHandle() |
StatementMetricHandle |
NamedWindowProcessor.getCreateNamedWindowMetricsHandle() |
Modifier and Type | Method and Description |
---|---|
static NamedWindowOnExprFactory |
NamedWindowOnExprFactoryFactory.make(EventType namedWindowEventType,
String namedWindowName,
String namedWindowAlias,
OnTriggerDesc onTriggerDesc,
EventType filterEventType,
String filterStreamName,
boolean addToFront,
InternalEventRouter internalEventRouter,
EventType outputEventType,
StatementContext statementContext,
StatementMetricHandle createNamedWindowMetricsHandle,
boolean isDistinct,
StreamSelector optionalStreamSelector,
String optionalInsertIntoTableName) |
Constructor and Description |
---|
NamedWindowOnMergeViewFactory(EventType namedWindowEventType,
NamedWindowOnMergeHelper namedWindowOnMergeHelper,
StatementResultService statementResultService,
StatementMetricHandle createNamedWindowMetricHandle,
MetricReportingService metricReportingService) |
Modifier and Type | Method and Description |
---|---|
StatementMetricHandle |
TableOnMergeViewFactory.getMetricsHandle() |
Modifier and Type | Method and Description |
---|---|
static TableOnViewFactory |
TableOnViewFactoryFactory.make(TableMetadata tableMetadata,
OnTriggerDesc onTriggerDesc,
EventType filterEventType,
String filterStreamName,
StatementContext statementContext,
StatementMetricHandle metricsHandle,
boolean isDistinct,
InternalEventRouter internalEventRouter) |
Constructor and Description |
---|
TableOnMergeViewFactory(TableMetadata tableMetadata,
TableOnMergeHelper onMergeHelper,
StatementResultService statementResultService,
StatementMetricHandle metricsHandle,
MetricReportingServiceSPI metricReportingService) |