Package | Description |
---|---|
com.espertech.esper.common.client.dataflow.core |
Client API for data flows.
|
com.espertech.esper.common.client.hook.condition |
Conditions indicate special situations in the runtime.
|
com.espertech.esper.common.client.variable |
Classes for variable management
|
com.espertech.esper.common.internal.epl.dataflow.core | |
com.espertech.esper.common.internal.epl.rowrecog.state |
Match-recognize state management.
|
com.espertech.esper.common.internal.epl.variable.core | |
com.espertech.esper.common.internal.metrics.stmtmetrics |
Services for metrics reporting, including global flag, repositories and threading.
|
Modifier and Type | Method and Description |
---|---|
DeploymentIdNamePair[] |
EPDataFlowService.getDataFlows()
Returns the names of all declared data flows.
|
Modifier and Type | Method and Description |
---|---|
Map<DeploymentIdNamePair,Long> |
ConditionMatchRecognizeStatesMax.getCounts()
Returns the per-statement count.
|
Constructor and Description |
---|
ConditionMatchRecognizeStatesMax(long max,
Map<DeploymentIdNamePair,Long> counts)
Ctor.
|
Modifier and Type | Method and Description |
---|---|
Map<DeploymentIdNamePair,Object> |
EPVariableService.getVariableValue(Set<DeploymentIdNamePair> variableNames)
Returns current variable values for each of the global variable names passed in,
guaranteeing consistency in the face of concurrent updates to the variables.
|
Map<DeploymentIdNamePair,List<ContextPartitionVariableState>> |
EPVariableService.getVariableValue(Set<DeploymentIdNamePair> variableNames,
ContextPartitionSelector contextPartitionSelector)
Returns the current variable values for a context-partitioned variable, per context partition.
|
Map<DeploymentIdNamePair,Object> |
EPVariableService.getVariableValueAll()
Returns current variable values for all global variables,
guaranteeing consistency in the face of concurrent updates to the variables.
|
Modifier and Type | Method and Description |
---|---|
Map<DeploymentIdNamePair,Object> |
EPVariableService.getVariableValue(Set<DeploymentIdNamePair> variableNames)
Returns current variable values for each of the global variable names passed in,
guaranteeing consistency in the face of concurrent updates to the variables.
|
Map<DeploymentIdNamePair,List<ContextPartitionVariableState>> |
EPVariableService.getVariableValue(Set<DeploymentIdNamePair> variableNames,
ContextPartitionSelector contextPartitionSelector)
Returns the current variable values for a context-partitioned variable, per context partition.
|
void |
EPVariableService.setVariableValue(Map<DeploymentIdNamePair,Object> variableValues)
Sets the value of multiple global variables in one update, applying all or none of the changes
to variable values in one atomic transaction.
|
void |
EPVariableService.setVariableValue(Map<DeploymentIdNamePair,Object> variableValues,
int agentInstanceId)
Sets the value of multiple context-partitioned variables in one update, applying all or none of the changes
to variable values in one atomic transaction.
|
Modifier and Type | Method and Description |
---|---|
DeploymentIdNamePair[] |
EPDataFlowServiceImpl.getDataFlows() |
Modifier and Type | Method and Description |
---|---|
DeploymentIdNamePair |
RowRecogStatePoolRuntimeSvc.StatementEntry.getStatement() |
Modifier and Type | Method and Description |
---|---|
void |
RowRecogStatePoolRuntimeSvc.addPatternContext(DeploymentIdNamePair statement,
RowRecogStatePoolStmtHandler stmtCounts) |
void |
RowRecogStatePoolRuntimeSvc.removeStatement(DeploymentIdNamePair statement) |
Constructor and Description |
---|
StatementEntry(DeploymentIdNamePair statement,
RowRecogStatePoolStmtHandler stmtCounts) |
Modifier and Type | Method and Description |
---|---|
Map<DeploymentIdNamePair,VariableReader> |
VariableManagementServiceImpl.getVariableReadersNonCP() |
Map<DeploymentIdNamePair,VariableReader> |
VariableManagementService.getVariableReadersNonCP() |
Modifier and Type | Method and Description |
---|---|
StatementMetricHandle |
StatementMetricRepository.addStatement(DeploymentIdNamePair statement)
Add a statement, inspecting the statement name and adding it to a statement group or the default group, if none.
|
int |
StatementMetricArray.addStatementGetIndex(DeploymentIdNamePair statement)
Adds a statement and returns the index added at.
|
void |
StatementMetricRepository.removeStatement(DeploymentIdNamePair statement)
Remove statement.
|
void |
StatementMetricArray.removeStatement(DeploymentIdNamePair statement)
Remove a statement.
|
Copyright © 2005–2021. All rights reserved.