Package | Description |
---|---|
com.espertech.esper.client |
This package and its sub-packages defines the central Esper Client APIs.
|
com.espertech.esper.client.dataflow |
Client API for data flows.
|
com.espertech.esper.client.deploy |
Module and deployment administrative service.
|
com.espertech.esper.core.service |
Implementation of client package interfaces, glue code
|
com.espertech.esper.dataflow.ops |
Data flow built-in operators.
|
com.espertech.esper.util |
Utility classes that center around Java type handling, printing, reflection, debugging
|
Modifier and Type | Method and Description |
---|---|
EPStatement |
EPAdministrator.create(EPPreparedStatement prepared)
Creates and starts a prepared statement.
|
EPStatement |
EPAdministrator.create(EPPreparedStatement prepared,
java.lang.String statementName)
Creates and starts a prepared statement.
|
EPStatement |
EPAdministrator.create(EPPreparedStatement prepared,
java.lang.String statementName,
java.lang.Object userObject)
Creates and starts a prepared statement.
|
EPStatement |
EPAdministrator.create(EPStatementObjectModel sodaStatement)
Creates and starts an EPL statement.
|
EPStatement |
EPAdministrator.create(EPStatementObjectModel sodaStatement,
java.lang.String statementName)
Creates and starts an EPL statement.
|
EPStatement |
EPAdministrator.create(EPStatementObjectModel sodaStatement,
java.lang.String statementName,
java.lang.Object userObject)
Creates and starts an EPL statement.
|
EPStatement |
EPAdministrator.createEPL(java.lang.String eplStatement)
Creates and starts an EPL statement.
|
EPStatement |
EPAdministrator.createEPL(java.lang.String eplStatement,
java.lang.Object userObject)
Create and starts an EPL statement.
|
EPStatement |
EPAdministrator.createEPL(java.lang.String eplStatement,
java.lang.String statementName)
Create and starts an EPL statement.
|
EPStatement |
EPAdministratorIsolated.createEPL(java.lang.String eplStatement,
java.lang.String statementName,
java.lang.Object userObject)
Create and starts an EPL statement.
|
EPStatement |
EPAdministrator.createEPL(java.lang.String eplStatement,
java.lang.String statementName,
java.lang.Object userObject)
Create and starts an EPL statement.
|
EPStatement |
EPAdministrator.createPattern(java.lang.String onExpression)
Create and starts an event pattern statement for the expressing string passed.
|
EPStatement |
EPAdministrator.createPattern(java.lang.String onExpression,
java.lang.Object userObject)
Create and starts an event pattern statement for the expressing string passed and assign the name passed.
|
EPStatement |
EPAdministrator.createPattern(java.lang.String onExpression,
java.lang.String statementName)
Create and starts an event pattern statement for the expressing string passed and assign the name passed.
|
EPStatement |
EPAdministrator.createPattern(java.lang.String onExpression,
java.lang.String statementName,
java.lang.Object userObject)
Create and starts an event pattern statement for the expressing string passed and assign the name passed.
|
EPStatement |
EPAdministrator.getStatement(java.lang.String name)
Returns the statement by the given statement name.
|
Modifier and Type | Method and Description |
---|---|
void |
EPAdministratorIsolated.addStatement(EPStatement statement)
Add a statement to the isolated service.
|
void |
EPAdministratorIsolated.addStatement(EPStatement[] statements)
Add statements to the isolated service.
|
void |
EPStatementStateListener.onStatementCreate(EPServiceProvider serviceProvider,
EPStatement statement)
Called to indicate that a new statement has been created in stopped state.
|
void |
EPStatementStateListener.onStatementStateChange(EPServiceProvider serviceProvider,
EPStatement statement)
Called to indicate that a statement has changed state.
|
void |
EPAdministratorIsolated.removeStatement(EPStatement statement)
Remove a statement from the isolated service.
|
void |
EPAdministratorIsolated.removeStatement(EPStatement[] statements)
Remove statements from the isolated service.
|
void |
StatementAwareUpdateListener.update(EventBean[] newEvents,
EventBean[] oldEvents,
EPStatement statement,
EPServiceProvider epServiceProvider)
Notify that new events are available or old events are removed.
|
Modifier and Type | Method and Description |
---|---|
EPStatement |
EPDataFlowIRStreamCollectorContext.getStatement()
Returns the statement.
|
Modifier and Type | Method and Description |
---|---|
boolean |
EPDataFlowEPStatementFilter.pass(EPStatement statement)
Pass or skip the statement.
|
void |
EPDataFlowIRStreamCollectorContext.setStatement(EPStatement statement)
Sets statement.
|
Constructor and Description |
---|
EPDataFlowIRStreamCollectorContext(EPDataFlowEmitter emitter,
boolean submitEventBean,
EventBean[] newEvents,
EventBean[] oldEvents,
EPStatement statement,
EPServiceProvider epServiceProvider)
Ctor.
|
Modifier and Type | Method and Description |
---|---|
java.util.List<EPStatement> |
DeploymentResult.getStatements()
Returns the statements.
|
Constructor and Description |
---|
DeploymentResult(java.lang.String deploymentId,
java.util.List<EPStatement> statements,
java.util.List<java.lang.String> imports)
Ctor.
|
Modifier and Type | Interface and Description |
---|---|
interface |
EPStatementSPI
Statement SPI for statements operations for state transitions and internal management.
|
Modifier and Type | Class and Description |
---|---|
class |
EPStatementImpl
Statement implementation for EPL statements.
|
Modifier and Type | Field and Description |
---|---|
protected EPStatement |
ResultDeliveryStrategyTypeArr.statement |
protected EPStatement |
ResultDeliveryStrategyObjectArr.statement |
protected EPStatement |
ResultDeliveryStrategyMap.statement |
Modifier and Type | Field and Description |
---|---|
protected java.util.Map<java.lang.String,EPStatement> |
StatementLifecycleSvcImpl.stmtNameToStmtMap
Map of statement name to statement.
|
Modifier and Type | Method and Description |
---|---|
EPStatement |
EPAdministratorImpl.create(EPPreparedStatement prepared) |
EPStatement |
EPAdministratorImpl.create(EPPreparedStatement prepared,
java.lang.String statementName) |
EPStatement |
EPAdministratorImpl.create(EPPreparedStatement prepared,
java.lang.String statementName,
java.lang.Object userObject) |
EPStatement |
EPAdministratorImpl.create(EPPreparedStatement prepared,
java.lang.String statementName,
java.lang.Object userObject,
java.lang.Integer optionalStatementId) |
EPStatement |
EPAdministratorImpl.create(EPStatementObjectModel sodaStatement) |
EPStatement |
EPAdministratorImpl.create(EPStatementObjectModel sodaStatement,
java.lang.String statementName) |
EPStatement |
EPAdministratorImpl.create(EPStatementObjectModel sodaStatement,
java.lang.String statementName,
java.lang.Object userObject) |
EPStatement |
EPAdministratorImpl.create(EPStatementObjectModel sodaStatement,
java.lang.String statementName,
java.lang.Object userObject,
java.lang.Integer optionalStatementId) |
EPStatement |
StatementLifecycleSvcImpl.createAndStart(StatementSpecRaw statementSpec,
java.lang.String expression,
boolean isPattern,
java.lang.String optStatementName,
java.lang.Object userObject,
EPIsolationUnitServices isolationUnitServices,
java.lang.Integer optionalStatementId,
EPStatementObjectModel optionalModel) |
EPStatement |
StatementLifecycleSvc.createAndStart(StatementSpecRaw statementSpec,
java.lang.String expression,
boolean isPattern,
java.lang.String optStatementName,
java.lang.Object userObject,
EPIsolationUnitServices isolationUnitServices,
java.lang.Integer optionalStatementId,
EPStatementObjectModel optionalModel)
Create and start the statement.
|
EPStatement |
EPAdministratorImpl.createEPL(java.lang.String eplStatement) |
EPStatement |
EPAdministratorImpl.createEPL(java.lang.String eplStatement,
java.lang.Object userObject) |
EPStatement |
EPAdministratorImpl.createEPL(java.lang.String eplStatement,
java.lang.String statementName) |
EPStatement |
EPAdministratorIsolatedImpl.createEPL(java.lang.String eplStatement,
java.lang.String statementName,
java.lang.Object userObject) |
EPStatement |
EPAdministratorImpl.createEPL(java.lang.String eplStatement,
java.lang.String statementName,
java.lang.Object userObject) |
EPStatement |
EPAdministratorSPI.createEPLStatementId(java.lang.String eplStatement,
java.lang.String statementName,
java.lang.Object userObject,
int statementId) |
EPStatement |
EPAdministratorImpl.createEPLStatementId(java.lang.String eplStatement,
java.lang.String statementName,
java.lang.Object userObject,
int statementId) |
EPStatement |
EPAdministratorIsolatedSPI.createEPLStatementId(java.lang.String eplStatement,
java.lang.String statementName,
java.lang.Object userObject,
java.lang.Integer optionalStatementId) |
EPStatement |
EPAdministratorIsolatedImpl.createEPLStatementId(java.lang.String eplStatement,
java.lang.String statementName,
java.lang.Object userObject,
java.lang.Integer optionalStatementId) |
EPStatement |
EPAdministratorSPI.createModelStatementId(EPStatementObjectModel sodaStatement,
java.lang.String statementName,
java.lang.Object userObject,
int statementId) |
EPStatement |
EPAdministratorImpl.createModelStatementId(EPStatementObjectModel sodaStatement,
java.lang.String statementName,
java.lang.Object userObject,
int statementId) |
EPStatement |
EPAdministratorImpl.createPattern(java.lang.String onExpression) |
EPStatement |
EPAdministratorImpl.createPattern(java.lang.String expression,
java.lang.Object userObject) |
EPStatement |
EPAdministratorImpl.createPattern(java.lang.String expression,
java.lang.String statementName) |
EPStatement |
EPAdministratorImpl.createPattern(java.lang.String expression,
java.lang.String statementName,
java.lang.Object userObject) |
EPStatement |
EPAdministratorSPI.createPatternStatementId(java.lang.String pattern,
java.lang.String statementName,
java.lang.Object userObject,
int statementId) |
EPStatement |
EPAdministratorImpl.createPatternStatementId(java.lang.String pattern,
java.lang.String statementName,
java.lang.Object userObject,
int statementId) |
EPStatement |
EPAdministratorSPI.createPreparedEPLStatementId(EPPreparedStatementImpl prepared,
java.lang.String statementName,
java.lang.Object userObject,
int statementId) |
EPStatement |
EPAdministratorImpl.createPreparedEPLStatementId(EPPreparedStatementImpl prepared,
java.lang.String statementName,
java.lang.Object userObject,
int statementId) |
EPStatement |
StatementLifecycleEvent.getStatement()
Returns the statement instance for the event.
|
EPStatement |
EPAdministratorImpl.getStatement(java.lang.String name) |
EPStatement |
StatementLifecycleSvcImpl.getStatementByName(java.lang.String name) |
EPStatement |
StatementLifecycleSvc.getStatementByName(java.lang.String name)
Returns the statement by the given name, or null if no such statement exists.
|
Modifier and Type | Method and Description |
---|---|
java.util.Map<java.lang.String,EPStatement> |
StatementLifecycleSvcImpl.getStmtNameToStmt() |
java.util.Map<java.lang.String,EPStatement> |
StatementLifecycleSvc.getStmtNameToStmt() |
Modifier and Type | Method and Description |
---|---|
void |
EPAdministratorIsolatedImpl.addStatement(EPStatement stmt) |
void |
EPAdministratorIsolatedImpl.addStatement(EPStatement[] stmt) |
void |
StatementIsolationServiceImpl.beginIsolatingStatements(java.lang.String name,
int unitId,
EPStatement[] stmt) |
void |
StatementIsolationService.beginIsolatingStatements(java.lang.String name,
int unitId,
EPStatement[] stmt)
Indicates statements are moved to isolation.
|
void |
StatementIsolationServiceImpl.beginUnisolatingStatements(java.lang.String name,
int unitId,
EPStatement[] stmt) |
void |
StatementIsolationService.beginUnisolatingStatements(java.lang.String name,
int unitId,
EPStatement[] stmt)
Indicates statements are moved out of isolation.
|
void |
StatementIsolationServiceImpl.commitIsolatingStatements(java.lang.String name,
int unitId,
EPStatement[] stmt) |
void |
StatementIsolationService.commitIsolatingStatements(java.lang.String name,
int unitId,
EPStatement[] stmt)
Indicates statements are have moved to isolation.
|
void |
StatementIsolationServiceImpl.commitUnisolatingStatements(java.lang.String name,
int unitId,
EPStatement[] stmt) |
void |
StatementIsolationService.commitUnisolatingStatements(java.lang.String name,
int unitId,
EPStatement[] stmt)
Indicates statements have been moved out of isolation.
|
static ResultDeliveryStrategy |
ResultDeliveryStrategyFactory.create(EPStatement statement,
java.lang.Object subscriber,
java.lang.String methodName,
java.lang.Class[] selectClauseTypes,
java.lang.String[] selectClauseColumns,
java.lang.String engineURI,
EngineImportService engineImportService)
Creates a strategy implementation that indicates to subscribers
the statement results based on the select-clause columns.
|
void |
EPAdministratorIsolatedImpl.removeStatement(EPStatement stmt) |
void |
EPAdministratorIsolatedImpl.removeStatement(EPStatement[] stmt) |
void |
StatementIsolationServiceImpl.rollbackIsolatingStatements(java.lang.String name,
int unitId,
EPStatement[] stmt) |
void |
StatementIsolationService.rollbackIsolatingStatements(java.lang.String name,
int unitId,
EPStatement[] stmt)
Indicates statements are have not moved to isolation.
|
void |
StatementIsolationServiceImpl.rollbackUnisolatingStatements(java.lang.String name,
int unitId,
EPStatement[] stmt) |
void |
StatementIsolationService.rollbackUnisolatingStatements(java.lang.String name,
int unitId,
EPStatement[] stmt)
Indicates statements are not moved out of isolation.
|
void |
StatementLifecycleSvcImpl.updatedListeners(EPStatement statement,
EPStatementListenerSet listeners,
boolean isRecovery) |
void |
StatementLifecycleSvc.updatedListeners(EPStatement stmt,
EPStatementListenerSet listeners,
boolean isRecovery)
Statements indicate that listeners have been added through this method.
|
Constructor and Description |
---|
DeliveryConvertorMapWStatement(java.lang.String[] columnNames,
EPStatement statement) |
DeliveryConvertorNullWStatement(EPStatement statement) |
DeliveryConvertorObjectArrWStatement(EPStatement statement) |
DeliveryConvertorWidenerWStatement(TypeWidener[] wideners,
EPStatement statement) |
ResultDeliveryStrategyImpl(EPStatement statement,
java.lang.Object subscriber,
DeliveryConvertor deliveryConvertor,
java.lang.reflect.Method method,
java.lang.reflect.Method startMethod,
java.lang.reflect.Method endMethod,
java.lang.reflect.Method rStreamMethod,
EngineImportService engineImportService)
Ctor.
|
ResultDeliveryStrategyMap(EPStatement statement,
java.lang.Object subscriber,
java.lang.reflect.Method method,
java.lang.String[] columnNames,
EngineImportService engineImportService)
Ctor.
|
ResultDeliveryStrategyMapWStmt(EPStatement statement,
java.lang.Object subscriber,
java.lang.reflect.Method method,
java.lang.String[] columnNames,
EngineImportService engineImportService) |
ResultDeliveryStrategyObjectArr(EPStatement statement,
java.lang.Object subscriber,
java.lang.reflect.Method method,
EngineImportService engineImportService)
Ctor.
|
ResultDeliveryStrategyObjectArrWStmt(EPStatement statement,
java.lang.Object subscriber,
java.lang.reflect.Method method,
EngineImportService engineImportService) |
ResultDeliveryStrategyTypeArr(EPStatement statement,
java.lang.Object subscriber,
java.lang.reflect.Method method,
java.lang.Class componentType,
EngineImportService engineImportService)
Ctor.
|
ResultDeliveryStrategyTypeArrWStmt(EPStatement statement,
java.lang.Object subscriber,
java.lang.reflect.Method method,
java.lang.Class componentType,
EngineImportService engineImportService) |
StatementLifecycleEvent(EPStatement statement,
StatementLifecycleEvent.LifecycleEventType eventType,
java.lang.Object... parameters)
Ctor.
|
Modifier and Type | Method and Description |
---|---|
void |
EPStatementSource.EmitterUpdateListener.update(EventBean[] newEvents,
EventBean[] oldEvents,
EPStatement statement,
EPServiceProvider epServiceProvider) |
void |
EPStatementSource.EmitterCollectorUpdateListener.update(EventBean[] newEvents,
EventBean[] oldEvents,
EPStatement statement,
EPServiceProvider epServiceProvider) |
Modifier and Type | Method and Description |
---|---|
static boolean |
StatementSelectionUtil.evaluateStatement(ExprNode expression,
EPStatement stmt) |
Modifier and Type | Method and Description |
---|---|
static void |
StatementSelectionUtil.applyExpressionToStatements(EPServiceProviderSPI engine,
java.lang.String filter,
java.util.function.BiConsumer<EPServiceProvider,EPStatement> consumer) |