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,
String statementName)
Creates and starts a prepared statement.
|
EPStatement |
EPAdministrator.create(EPPreparedStatement prepared,
String statementName,
Object userObject)
Creates and starts a prepared statement.
|
EPStatement |
EPAdministrator.create(EPStatementObjectModel sodaStatement)
Creates and starts an EPL statement.
|
EPStatement |
EPAdministrator.create(EPStatementObjectModel sodaStatement,
String statementName)
Creates and starts an EPL statement.
|
EPStatement |
EPAdministrator.create(EPStatementObjectModel sodaStatement,
String statementName,
Object userObject)
Creates and starts an EPL statement.
|
EPStatement |
EPAdministrator.createEPL(String eplStatement)
Creates and starts an EPL statement.
|
EPStatement |
EPAdministrator.createEPL(String eplStatement,
Object userObject)
Create and starts an EPL statement.
|
EPStatement |
EPAdministrator.createEPL(String eplStatement,
String statementName)
Create and starts an EPL statement.
|
EPStatement |
EPAdministratorIsolated.createEPL(String eplStatement,
String statementName,
Object userObject)
Create and starts an EPL statement.
|
EPStatement |
EPAdministrator.createEPL(String eplStatement,
String statementName,
Object userObject)
Create and starts an EPL statement.
|
EPStatement |
EPAdministrator.createPattern(String onExpression)
Create and starts an event pattern statement for the expressing string passed.
|
EPStatement |
EPAdministrator.createPattern(String onExpression,
Object userObject)
Create and starts an event pattern statement for the expressing string passed and assign the name passed.
|
EPStatement |
EPAdministrator.createPattern(String onExpression,
String statementName)
Create and starts an event pattern statement for the expressing string passed and assign the name passed.
|
EPStatement |
EPAdministrator.createPattern(String onExpression,
String statementName,
Object userObject)
Create and starts an event pattern statement for the expressing string passed and assign the name passed.
|
EPStatement |
EPAdministrator.getStatement(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 |
---|---|
List<EPStatement> |
DeploymentResult.getStatements()
Returns the statements.
|
Constructor and Description |
---|
DeploymentResult(String deploymentId,
List<EPStatement> statements,
List<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 Map<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,
String statementName) |
EPStatement |
EPAdministratorImpl.create(EPPreparedStatement prepared,
String statementName,
Object userObject) |
EPStatement |
EPAdministratorImpl.create(EPPreparedStatement prepared,
String statementName,
Object userObject,
Integer optionalStatementId) |
EPStatement |
EPAdministratorImpl.create(EPStatementObjectModel sodaStatement) |
EPStatement |
EPAdministratorImpl.create(EPStatementObjectModel sodaStatement,
String statementName) |
EPStatement |
EPAdministratorImpl.create(EPStatementObjectModel sodaStatement,
String statementName,
Object userObject) |
EPStatement |
EPAdministratorImpl.create(EPStatementObjectModel sodaStatement,
String statementName,
Object userObject,
Integer optionalStatementId) |
EPStatement |
StatementLifecycleSvcImpl.createAndStart(StatementSpecRaw statementSpec,
String expression,
boolean isPattern,
String optStatementName,
Object userObject,
EPIsolationUnitServices isolationUnitServices,
Integer optionalStatementId,
EPStatementObjectModel optionalModel) |
EPStatement |
StatementLifecycleSvc.createAndStart(StatementSpecRaw statementSpec,
String expression,
boolean isPattern,
String optStatementName,
Object userObject,
EPIsolationUnitServices isolationUnitServices,
Integer optionalStatementId,
EPStatementObjectModel optionalModel)
Create and start the statement.
|
EPStatement |
EPAdministratorImpl.createEPL(String eplStatement) |
EPStatement |
EPAdministratorImpl.createEPL(String eplStatement,
Object userObject) |
EPStatement |
EPAdministratorImpl.createEPL(String eplStatement,
String statementName) |
EPStatement |
EPAdministratorIsolatedImpl.createEPL(String eplStatement,
String statementName,
Object userObject) |
EPStatement |
EPAdministratorImpl.createEPL(String eplStatement,
String statementName,
Object userObject) |
EPStatement |
EPAdministratorSPI.createEPLStatementId(String eplStatement,
String statementName,
Object userObject,
int statementId) |
EPStatement |
EPAdministratorImpl.createEPLStatementId(String eplStatement,
String statementName,
Object userObject,
int statementId) |
EPStatement |
EPAdministratorIsolatedSPI.createEPLStatementId(String eplStatement,
String statementName,
Object userObject,
Integer optionalStatementId) |
EPStatement |
EPAdministratorIsolatedImpl.createEPLStatementId(String eplStatement,
String statementName,
Object userObject,
Integer optionalStatementId) |
EPStatement |
EPAdministratorSPI.createModelStatementId(EPStatementObjectModel sodaStatement,
String statementName,
Object userObject,
int statementId) |
EPStatement |
EPAdministratorImpl.createModelStatementId(EPStatementObjectModel sodaStatement,
String statementName,
Object userObject,
int statementId) |
EPStatement |
EPAdministratorImpl.createPattern(String onExpression) |
EPStatement |
EPAdministratorImpl.createPattern(String expression,
Object userObject) |
EPStatement |
EPAdministratorImpl.createPattern(String expression,
String statementName) |
EPStatement |
EPAdministratorImpl.createPattern(String expression,
String statementName,
Object userObject) |
EPStatement |
EPAdministratorSPI.createPatternStatementId(String pattern,
String statementName,
Object userObject,
int statementId) |
EPStatement |
EPAdministratorImpl.createPatternStatementId(String pattern,
String statementName,
Object userObject,
int statementId) |
EPStatement |
EPAdministratorSPI.createPreparedEPLStatementId(EPPreparedStatementImpl prepared,
String statementName,
Object userObject,
int statementId) |
EPStatement |
EPAdministratorImpl.createPreparedEPLStatementId(EPPreparedStatementImpl prepared,
String statementName,
Object userObject,
int statementId) |
EPStatement |
StatementLifecycleEvent.getStatement()
Returns the statement instance for the event.
|
EPStatement |
EPAdministratorImpl.getStatement(String name) |
EPStatement |
StatementLifecycleSvcImpl.getStatementByName(String name) |
EPStatement |
StatementLifecycleSvc.getStatementByName(String name)
Returns the statement by the given name, or null if no such statement exists.
|
Modifier and Type | Method and Description |
---|---|
Map<String,EPStatement> |
StatementLifecycleSvcImpl.getStmtNameToStmt() |
Map<String,EPStatement> |
StatementLifecycleSvc.getStmtNameToStmt() |
Modifier and Type | Method and Description |
---|---|
void |
EPAdministratorIsolatedImpl.addStatement(EPStatement stmt) |
void |
EPAdministratorIsolatedImpl.addStatement(EPStatement[] stmt) |
void |
StatementIsolationServiceImpl.beginIsolatingStatements(String name,
int unitId,
EPStatement[] stmt) |
void |
StatementIsolationService.beginIsolatingStatements(String name,
int unitId,
EPStatement[] stmt)
Indicates statements are moved to isolation.
|
void |
StatementIsolationServiceImpl.beginUnisolatingStatements(String name,
int unitId,
EPStatement[] stmt) |
void |
StatementIsolationService.beginUnisolatingStatements(String name,
int unitId,
EPStatement[] stmt)
Indicates statements are moved out of isolation.
|
void |
StatementIsolationServiceImpl.commitIsolatingStatements(String name,
int unitId,
EPStatement[] stmt) |
void |
StatementIsolationService.commitIsolatingStatements(String name,
int unitId,
EPStatement[] stmt)
Indicates statements are have moved to isolation.
|
void |
StatementIsolationServiceImpl.commitUnisolatingStatements(String name,
int unitId,
EPStatement[] stmt) |
void |
StatementIsolationService.commitUnisolatingStatements(String name,
int unitId,
EPStatement[] stmt)
Indicates statements have been moved out of isolation.
|
static ResultDeliveryStrategy |
ResultDeliveryStrategyFactory.create(EPStatement statement,
Object subscriber,
String methodName,
Class[] selectClauseTypes,
String[] selectClauseColumns,
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(String name,
int unitId,
EPStatement[] stmt) |
void |
StatementIsolationService.rollbackIsolatingStatements(String name,
int unitId,
EPStatement[] stmt)
Indicates statements are have not moved to isolation.
|
void |
StatementIsolationServiceImpl.rollbackUnisolatingStatements(String name,
int unitId,
EPStatement[] stmt) |
void |
StatementIsolationService.rollbackUnisolatingStatements(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.
|
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,
String filter,
BiConsumer<EPServiceProvider,EPStatement> consumer) |