| Package | Description |
|---|---|
| com.espertech.esper.adapter |
Adapter shared classes.
|
| com.espertech.esper.client |
This package and its sub-packages defines the central Esper Client APIs.
|
| com.espertech.esper.client.context |
Context partition selection and descriptors.
|
| com.espertech.esper.client.dataflow |
Client API for data flows.
|
| com.espertech.esper.core.service |
Implementation of client package interfaces, glue code
|
| com.espertech.esper.epl.expression.funcs |
Function expressions.
|
| com.espertech.esper.epl.expression.time |
Time-related expressions.
|
| com.espertech.esper.epl.index.service |
Advanced index provisioning
|
| com.espertech.esper.epl.join.table |
Indexes for views
|
| com.espertech.esper.epl.parse |
Parsers and AST tree walkers and helper classes transforming AST into business objects
|
| com.espertech.esper.event |
This package defines the internal event APIs.
|
| com.espertech.esper.event.bean |
JavaBean and legacy Java underlying event classes are here.
|
| com.espertech.esper.event.xml |
XML event wrappers
|
| com.espertech.esper.pattern |
Pattern expression tree and pattern state objects, the later resembles pattern expression state for each active
pattern instance
|
| com.espertech.esper.spatial.quadtree.mxcifrowindex |
Quadtree MXCIF row index
|
| com.espertech.esper.spatial.quadtree.prqdfilterindex |
Quadtree Point-region filter index
|
| com.espertech.esper.util |
Utility classes that center around Java type handling, printing, reflection, debugging
|
| Modifier and Type | Class and Description |
|---|---|
class |
IllegalStateTransitionException
Thrown when an illegal Adapter state transition is attempted.
|
| Modifier and Type | Method and Description |
|---|---|
void |
Adapter.destroy()
Destroy the Adapter, stopping the sending of all events and releasing all
the resources, and disallowing any further state changes on the Adapter.
|
void |
Adapter.pause()
Pause the sending of events after a Adapter has been started.
|
void |
Adapter.resume()
Resume sending events after the Adapter has been paused.
|
void |
Adapter.start()
Start the sending of events into the runtime egine.
|
void |
Adapter.stop()
Stop sending events and return the Adapter to the OPENED state, ready to be
started once again.
|
| Modifier and Type | Class and Description |
|---|---|
class |
ConfigurationException
Thrown to indicate a configuration problem.
|
class |
EPStatementException
This exception is thrown to indicate a problem in statement creation, such as syntax error or type checking problem
etc.
|
class |
EPStatementSyntaxException
This exception is thrown to indicate a problem in statement creation.
|
class |
EPSubscriberException
This exception is thrown to indicate that a subscriber registration failed
such as when the subscribe does not expose an acceptable method to receive statement results.
|
class |
EventTypeException
Indicates that a problem occurred looking up, assigning or creating and event type.
|
class |
VariableConstantValueException
Indicates that a variable cannot be set.
|
class |
VariableNotFoundException
Indicates that a variable was not found.
|
class |
VariableValueException
Indicates that a variable value could not be assigned.
|
| Modifier and Type | Method and Description |
|---|---|
EPStatementObjectModel |
EPAdministrator.compileEPL(String eplExpression)
Compiles a given EPL into an object model representation of the query.
|
Configuration |
Configuration.configure()
Use the configuration specified in an application
resource named esper.cfg.xml.
|
Configuration |
Configuration.configure(Document document)
Use the mappings and properties specified in the given XML document.
|
Configuration |
Configuration.configure(File configFile)
Use the configuration specified in the given application
file.
|
Configuration |
Configuration.configure(String resource)
Use the configuration specified in the given application
resource.
|
Configuration |
Configuration.configure(URL url)
Use the configuration specified by the given URL.
|
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.
|
void |
EPAdministrator.destroyAllStatements()
Stops and destroys all statements.
|
protected static InputStream |
Configuration.getConfigurationInputStream(String resource)
Get the configuration file as an InputStream.
|
EPPreparedStatement |
EPAdministrator.prepareEPL(String eplExpression)
Prepares a statement for the given EPL, which can include substitution parameters marked via question mark '?'.
|
EPPreparedStatement |
EPAdministrator.preparePattern(String patternExpression)
Prepares a statement for the given pattern, which can include substitution parameters marked via question mark '?'.
|
void |
EPRuntime.route(Map map,
String eventTypeName)
Route the event object back to the event stream processing runtime for internal dispatching,
to avoid the possibility of a stack overflow due to nested calls to sendEvent.
|
void |
EPRuntime.route(Node node)
Route the event object back to the event stream processing runtime for internal dispatching,
to avoid the possibility of a stack overflow due to nested calls to sendEvent.
|
void |
EventSender.route(Object theEvent)
Route the event object back to the event stream processing runtime for internal dispatching,
to avoid the possibility of a stack overflow due to nested calls to sendEvent.
|
void |
EPRuntime.route(Object[] objectArray,
String eventTypeName)
Route the event object back to the event stream processing runtime for internal dispatching,
to avoid the possibility of a stack overflow due to nested calls to sendEvent.
|
void |
EPRuntime.routeAvro(Object avroGenericDataDotRecord,
String avroEventTypeName)
Route the event object back to the event stream processing runtime for internal dispatching,
to avoid the possibility of a stack overflow due to nested calls to sendEvent.
|
void |
EPRuntimeIsolated.sendEvent(Map map,
String eventTypeName)
Send a map containing event property values to the event stream processing runtime.
|
void |
EPRuntime.sendEvent(Map map,
String mapEventTypeName)
Send a map containing event property values to the event stream processing runtime.
|
void |
EPRuntimeIsolated.sendEvent(Node node)
Send an event represented by a DOM node to the event stream processing runtime.
|
void |
EPRuntime.sendEvent(Node node)
Send an event represented by a DOM node to the event stream processing runtime.
|
void |
EventSender.sendEvent(Object theEvent)
Processes the event object.
|
void |
EPRuntimeIsolated.sendEvent(Object object)
Send an event represented by a plain Java object to the event stream processing runtime.
|
void |
EPRuntime.sendEvent(Object object)
Send an event represented by a plain Java object to the event stream processing runtime.
|
void |
EPPreparedStatement.setObject(int parameterIndex,
Object value)
Sets the value of the designated parameter using the given object.
|
void |
EPOnDemandPreparedQueryParameterized.setObject(int parameterIndex,
Object value)
Sets the value of the designated parameter using the given object.
|
void |
EPPreparedStatement.setObject(String parameterName,
Object value)
Sets the value of the designated parameter using the given object.
|
void |
EPAdministrator.startAllStatements()
Starts all statements that are in stopped state.
|
void |
EPAdministrator.stopAllStatements()
Stops all statements that are in started state.
|
| Modifier and Type | Class and Description |
|---|---|
class |
InvalidContextPartitionSelector
Indicates an invalid combination of context declaration and context partition selector, i.e.
|
| Modifier and Type | Class and Description |
|---|---|
class |
EPDataFlowAlreadyExistsException
Thrown to indicate a data flow saved configuration already exists.
|
class |
EPDataFlowCancellationException
Indicates cancellation of a data flow instance.
|
class |
EPDataFlowExecutionException
Thrown to indicate a data flow execution exception.
|
class |
EPDataFlowInstantiationException
Indicates an exception instantiating a data flow.
|
class |
EPDataFlowNotFoundException
Thrown to indicate a data flow is not found.
|
| Modifier and Type | Method and Description |
|---|---|
void |
EventBusCollector.sendEvent(Map map,
String eventTypeName)
Send a map containing event property values to the event stream processing runtime.
|
void |
EventBusCollector.sendEvent(Node node)
Send an event represented by a DOM node to the event stream processing runtime.
|
void |
EventBusCollector.sendEvent(Object object)
Send an event represented by a plain Java object to the event stream processing runtime.
|
void |
EventBusCollector.sendEvent(Object[] objectArray,
String eventTypeName)
Send an object array containing event property values as array elements to the event stream processing runtime.
|
| Modifier and Type | Method and Description |
|---|---|
EPStatementObjectModel |
EPAdministratorImpl.compileEPL(String eplStatement) |
ExprNode |
EPAdministratorSPI.compileExpression(String expression)
Compile expression.
|
ExprNode |
EPAdministratorImpl.compileExpression(String expression) |
Expression |
EPAdministratorSPI.compileExpressionToSODA(String expression)
Compile expression.
|
Expression |
EPAdministratorImpl.compileExpressionToSODA(String expression) |
EvalFactoryNode |
EPAdministratorSPI.compilePatternToNode(String expression)
Compile pattern.
|
EvalFactoryNode |
EPAdministratorImpl.compilePatternToNode(String pattern) |
PatternExpr |
EPAdministratorSPI.compilePatternToSODA(String expression)
Compile pattern.
|
PatternExpr |
EPAdministratorImpl.compilePatternToSODA(String expression) |
EPStatementObjectModel |
EPAdministratorSPI.compilePatternToSODAModel(String expression)
Compile pattern.
|
EPStatementObjectModel |
EPAdministratorImpl.compilePatternToSODAModel(String expression) |
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 |
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) |
void |
StatementLifecycleSvcImpl.destroyAllStatements() |
void |
StatementLifecycleSvc.destroyAllStatements()
Destroys all started statements.
|
void |
EPAdministratorImpl.destroyAllStatements() |
Map<String,Object> |
EPRuntimeImpl.getVariableValue(Set<String> variableNames) |
Object |
EPRuntimeImpl.getVariableValue(String variableName) |
Map<String,Object> |
EPRuntimeImpl.getVariableValueAll() |
EPPreparedStatement |
EPAdministratorImpl.prepareEPL(String eplExpression) |
EPPreparedStatement |
EPAdministratorImpl.preparePattern(String patternExpression) |
void |
EPRuntimeImpl.route(Map map,
String eventTypeName) |
void |
EPRuntimeIsolatedImpl.route(Node document)
Route a XML docment event
|
void |
EPRuntimeImpl.route(Node document) |
void |
EPRuntimeImpl.route(Object[] objectArray,
String eventTypeName) |
void |
EPRuntimeImpl.routeAvro(Object avroGenericDataDotRecord,
String avroEventTypeName) |
void |
EPRuntimeIsolatedImpl.sendEvent(Map map,
String eventTypeName) |
void |
EPRuntimeImpl.sendEvent(Map map,
String mapEventTypeName) |
void |
EPRuntimeIsolatedImpl.sendEvent(Node document) |
void |
EPRuntimeImpl.sendEvent(Node document) |
void |
EPRuntimeIsolatedImpl.sendEvent(Object theEvent) |
void |
EPRuntimeImpl.sendEvent(Object theEvent) |
void |
EPRuntimeImpl.sendEvent(Object[] propertyValues,
String objectArrayEventTypeName) |
void |
EPPreparedStatementImpl.setObject(int parameterIndex,
Object value) |
void |
EPPreparedStatementImpl.setObject(String parameterName,
Object value) |
void |
EPRuntimeImpl.setVariableValue(Map<String,Object> variableValues) |
void |
EPRuntimeImpl.setVariableValue(String variableName,
Object variableValue) |
void |
StatementLifecycleSvcImpl.startAllStatements() |
void |
StatementLifecycleSvc.startAllStatements()
Starts all stopped statements.
|
void |
EPAdministratorImpl.startAllStatements() |
void |
StatementLifecycleSvcImpl.stopAllStatements() |
void |
StatementLifecycleSvc.stopAllStatements()
Stops all started statements.
|
void |
EPAdministratorImpl.stopAllStatements() |
| Modifier and Type | Method and Description |
|---|---|
static EPException |
ExprCastNode.handleParseException(String formatString,
String date,
Exception ex) |
static EPException |
ExprCastNode.handleParseISOException(String date,
ScheduleParameterException ex) |
| Modifier and Type | Method and Description |
|---|---|
static EPException |
ExprTimePeriodForge.makeTimePeriodParamNullException(String expressionText)
NOTE: Code-generation-invoked method, method name and parameter order matters
|
| Modifier and Type | Method and Description |
|---|---|
static EPException |
AdvancedIndexEvaluationHelper.invalidColumnValue(String indexName,
String parameterName,
Object value,
String expected) |
static EPException |
AdvancedIndexEvaluationHelper.invalidParameterValue(String indexName,
String parameterName,
Object value,
String expected) |
| Modifier and Type | Method and Description |
|---|---|
static EPException |
PropertyIndexedEventTableUnique.handleUniqueIndexViolation(String indexName,
Object key) |
| Modifier and Type | Method and Description |
|---|---|
static ParseResult |
ParseHelper.parse(String expression,
String eplStatementErrorMsg,
boolean addPleaseCheck,
ParseRuleSelector parseRuleSelector,
boolean rewriteScript)
Parse expression using the rule the ParseRuleSelector instance supplies.
|
static CreateSchemaDesc |
ASTCreateSchemaHelper.walkCreateSchema(EsperEPL2GrammarParser.CreateSchemaExprContext ctx) |
| Modifier and Type | Class and Description |
|---|---|
class |
EventAdapterException
This exception is thrown to indicate a problem resolving an event type by name.
|
| Modifier and Type | Method and Description |
|---|---|
EventBean |
EventAdapterServiceImpl.adapterForMap(Map<String,Object> theEvent,
String eventTypeName) |
EventBean |
EventAdapterServiceImpl.adapterForObjectArray(Object[] theEvent,
String eventTypeName) |
static PropertySetDescriptor |
EventTypeUtility.getNestableProperties(Map<String,Object> propertiesToAdd,
EventAdapterService eventAdapterService,
EventTypeNestableGetterFactory factory,
EventType[] optionalSuperTypes) |
void |
EventSenderXMLDOM.route(Object theEvent) |
void |
EventSenderImpl.route(Object theEvent) |
void |
EventSenderBean.route(Object theEvent) |
void |
EventSenderXMLDOM.sendEvent(Object theEvent) |
void |
EventSenderImpl.sendEvent(Object theEvent) |
static EventTypeUtility.TimestampPropertyDesc |
EventTypeUtility.validatedDetermineTimestampProps(EventType type,
String startProposed,
String endProposed,
EventType[] superTypes) |
| Modifier and Type | Method and Description |
|---|---|
static EPException |
InstanceManufacturerFastCtor.getTargetExceptionAsEPException(String targetClassName,
Throwable targetException)
NOTE: Code-generation-invoked method, method name and parameter order matters
|
| Modifier and Type | Method and Description |
|---|---|
static EventPropertyGetterSPI |
SchemaXMLPropertyParser.getXPathResolution(String propertyName,
XPathFactory xPathFactory,
String rootElementName,
String namespace,
SchemaModel schemaModel,
EventAdapterService eventAdapterService,
BaseXMLEventType xmlEventType,
boolean isAllowFragment,
String defaultNamespace)
Return the xPath corresponding to the given property.
|
| Modifier and Type | Method and Description |
|---|---|
static Object |
PatternExpressionUtil.evaluate(String objectName,
MatchedEventMap beginState,
ExprNode parameter,
MatchedEventConvertor convertor,
ExprEvaluatorContext exprEvaluatorContext) |
static List<Object> |
PatternExpressionUtil.evaluate(String objectName,
MatchedEventMap beginState,
List<ExprNode> parameters,
MatchedEventConvertor convertor,
ExprEvaluatorContext exprEvaluatorContext)
Ctor.
|
static Object |
PatternExpressionUtil.evaluateTimePeriod(String objectName,
MatchedEventMap beginState,
ExprTimePeriod timePeriod,
MatchedEventConvertor convertor,
ExprEvaluatorContext exprEvaluatorContext)
Evaluate the pattern expression.
|
| Modifier and Type | Method and Description |
|---|---|
static void |
MXCIFQuadTreeFilterIndexCheckBB.checkBB(BoundingBox bb,
double x,
double y,
double width,
double height) |
| Modifier and Type | Method and Description |
|---|---|
static void |
PointRegionQuadTreeFilterIndexCheckBB.checkBB(BoundingBox bb,
double x,
double y) |
| Modifier and Type | Class and Description |
|---|---|
class |
ClassInstantiationException
Exception to represent an error instantiating a class from a class name.
|
class |
CoercionException
Exception to represent a mismatch in Java types in an expression.
|
| Modifier and Type | Method and Description |
|---|---|
static void |
ValidationUtil.validateRequiredProp(Object value,
String operatorName,
String propertyName) |
static void |
ValidationUtil.validateRequiredPropString(String value,
String operatorName,
String propertyName) |