Package | Description |
---|---|
com.espertech.esper.runtime.client |
Runtime API: Runs compiled EPL.
|
com.espertech.esper.runtime.client.scopetest |
Runtime-related classes for facilitating automated regression testing.
|
com.espertech.esper.runtime.internal.dataflow.op.epstatementsource | |
com.espertech.esper.runtime.internal.deploymentlifesvc | |
com.espertech.esper.runtime.internal.kernel.service | |
com.espertech.esper.runtime.internal.kernel.statement | |
com.espertech.esper.runtime.internal.metrics.stmtmetrics | |
com.espertech.esper.runtime.internal.subscriber |
Modifier and Type | Method and Description |
---|---|
EPStatement |
EPDeploymentService.getStatement(String deploymentId,
String statementName)
Returns the statement of a given deployment.
|
EPStatement[] |
EPDeployment.getStatements()
Returns the statements
|
EPStatement[] |
DeploymentStateEvent.getStatements()
Returns the statements for the deployment or undeployment
|
Modifier and Type | Method and Description |
---|---|
void |
UpdateListener.update(com.espertech.esper.common.client.EventBean[] newEvents,
com.espertech.esper.common.client.EventBean[] oldEvents,
EPStatement statement,
EPRuntime runtime)
Notify that new events are available or old events are removed.
|
Constructor and Description |
---|
DeploymentStateEvent(String runtimeURI,
String deploymentId,
String moduleName,
EPStatement[] statements)
Ctor
|
DeploymentStateEventDeployed(String runtimeURI,
String deploymentId,
String moduleName,
EPStatement[] statements)
Ctor.
|
DeploymentStateEventUndeployed(String runtimeURI,
String deploymentId,
String moduleName,
EPStatement[] statements)
Ctor.
|
EPDeployment(String deploymentId,
String moduleName,
Map<com.espertech.esper.common.client.module.ModuleProperty,Object> moduleProperties,
EPStatement[] statements,
String[] deploymentIdDependencies,
Date lastUpdateDate)
Ctor.
|
Modifier and Type | Method and Description |
---|---|
void |
SupportUpdateListener.update(com.espertech.esper.common.client.EventBean[] newData,
com.espertech.esper.common.client.EventBean[] oldData,
EPStatement statement,
EPRuntime runtime) |
Modifier and Type | Method and Description |
---|---|
void |
EmitterUpdateListener.update(com.espertech.esper.common.client.EventBean[] newEvents,
com.espertech.esper.common.client.EventBean[] oldEvents,
EPStatement statement,
EPRuntime runtime) |
void |
EmitterCollectorUpdateListener.update(com.espertech.esper.common.client.EventBean[] newEvents,
com.espertech.esper.common.client.EventBean[] oldEvents,
EPStatement statement,
EPRuntime runtime) |
Modifier and Type | Method and Description |
---|---|
EPStatement |
StatementListenerEvent.getStatement()
Returns the statement instance for the event.
|
EPStatement |
DeploymentLifecycleServiceImpl.getStatementByName(String deploymentId,
String statementName) |
EPStatement |
DeploymentLifecycleService.getStatementByName(String deploymentId,
String statementName) |
Constructor and Description |
---|
StatementListenerEvent(EPStatement statement,
StatementListenerEvent.ListenerEventType eventType) |
StatementListenerEvent(EPStatement statement,
StatementListenerEvent.ListenerEventType eventType,
UpdateListener listener)
Ctor.
|
Modifier and Type | Method and Description |
---|---|
EPStatement |
EPDeploymentServiceImpl.getStatement(String deploymentId,
String statementName) |
EPStatement[] |
DeploymentInternal.getStatements() |
Modifier and Type | Method and Description |
---|---|
static void |
Undeployer.disassociate(EPStatement[] statements) |
boolean |
EPRuntimeStatementSelectionSPI.evaluateStatement(com.espertech.esper.common.internal.epl.expression.core.ExprNode expression,
EPStatement stmt) |
Modifier and Type | Method and Description |
---|---|
void |
EPRuntimeSPI.traverseStatements(BiConsumer<EPDeployment,EPStatement> consumer) |
void |
EPRuntimeImpl.traverseStatements(BiConsumer<EPDeployment,EPStatement> consumer) |
void |
EPRuntimeStatementSelectionSPI.traverseStatementsContains(BiConsumer<EPDeployment,EPStatement> consumer,
String containsIgnoreCase) |
void |
EPRuntimeStatementSelectionSPI.traverseStatementsFilterExpr(BiConsumer<EPDeployment,EPStatement> consumer,
com.espertech.esper.common.internal.epl.expression.core.ExprNode filterExpr) |
Constructor and Description |
---|
DeploymentInternal(String deploymentId,
EPStatement[] statements,
String[] deploymentIdDependencies,
String[] pathNamedWindows,
String[] pathTables,
String[] pathVariables,
String[] pathContexts,
String[] pathEventTypes,
String[] pathExprDecls,
com.espertech.esper.common.internal.epl.script.core.NameAndParamNum[] pathScripts,
com.espertech.esper.common.internal.context.module.ModuleIndexMeta[] pathIndexes,
com.espertech.esper.common.internal.context.module.ModuleProvider moduleProvider,
Map<com.espertech.esper.common.client.module.ModuleProperty,Object> modulePropertiesCached,
Map<Long,com.espertech.esper.common.client.EventType> deploymentTypes,
long lastUpdateDate) |
Modifier and Type | Interface and Description |
---|---|
interface |
EPStatementSPI |
Modifier and Type | Class and Description |
---|---|
class |
EPStatementImpl |
Modifier and Type | Method and Description |
---|---|
void |
MetricsStatementResultListener.update(int numIStream,
int numRStream,
EPStatement statement,
EPRuntime runtime) |
Modifier and Type | Field and Description |
---|---|
protected EPStatement |
ResultDeliveryStrategyTypeArr.statement |
protected EPStatement |
ResultDeliveryStrategyObjectArr.statement |
protected EPStatement |
ResultDeliveryStrategyMap.statement |
Modifier and Type | Method and Description |
---|---|
static ResultDeliveryStrategy |
ResultDeliveryStrategyFactory.create(EPStatement statement,
Object subscriber,
String methodName,
Class[] selectClauseTypes,
String[] selectClauseColumns,
String runtimeURI,
com.espertech.esper.common.internal.settings.ClasspathImportService classpathImportService)
Creates a strategy implementation that indicates to subscribers
the statement results based on the select-clause columns.
|
Constructor and Description |
---|
DeliveryConvertorMapWStatement(String[] columnNames,
EPStatement statement) |
DeliveryConvertorNullWStatement(EPStatement statement) |
DeliveryConvertorObjectArrWStatement(EPStatement statement) |
DeliveryConvertorStatementOnly(EPStatement statement) |
DeliveryConvertorWidenerWStatement(com.espertech.esper.common.internal.util.TypeWidenerSPI[] wideners,
EPStatement statement) |
ResultDeliveryStrategyImpl(EPStatement statement,
Object subscriber,
DeliveryConvertor deliveryConvertor,
Method method,
Method startMethod,
Method endMethod,
Method rStreamMethod,
com.espertech.esper.common.internal.settings.ClasspathImportService classpathImportService)
Ctor.
|
ResultDeliveryStrategyMap(EPStatement statement,
Object subscriber,
Method method,
String[] columnNames,
com.espertech.esper.common.internal.settings.ClasspathImportService classpathImportService)
Ctor.
|
ResultDeliveryStrategyMapWStmt(EPStatement statement,
Object subscriber,
Method method,
String[] columnNames,
com.espertech.esper.common.internal.settings.ClasspathImportService classpathImportService) |
ResultDeliveryStrategyObjectArr(EPStatement statement,
Object subscriber,
Method method,
com.espertech.esper.common.internal.settings.ClasspathImportService classpathImportService)
Ctor.
|
ResultDeliveryStrategyObjectArrWStmt(EPStatement statement,
Object subscriber,
Method method,
com.espertech.esper.common.internal.settings.ClasspathImportService classpathImportService) |
ResultDeliveryStrategyTypeArr(EPStatement statement,
Object subscriber,
Method method,
Class componentType,
com.espertech.esper.common.internal.settings.ClasspathImportService classpathImportService)
Ctor.
|
ResultDeliveryStrategyTypeArrWStmt(EPStatement statement,
Object subscriber,
Method method,
Class componentType,
com.espertech.esper.common.internal.settings.ClasspathImportService classpathImportService) |
Copyright © 2005–2018. All rights reserved.