All Classes and Interfaces
Class
Description
Provides the environment to
AccessModifierContextOption.Implement this interface to provide or override the access modifier a context.
Provides the environment to
AccessModifierEventTypeOption.Implement this interface to provide or override the access modifier for an event type.
Provides the environment to
AccessModifierExpressionOption.Implement this interface to provide or override the access modifier for a declared expression.
Provides the environment to
AccessModifierInlinedClassContext.Implement this interface to provide or override the access modifier for an inlined-class.
Provides the environment to
AccessModifierNamedWindowOption.Implement this interface to provide or override the access modifier for a named window.
Provides the environment to
AccessModifierScriptOption.Implement this interface to provide or override the access modifier for a script.
Provides the environment to
AccessModifierTableOption.Implement this interface to provide or override the access modifier for a table.
Provides the environment to
AccessModifierVariableOption.Implement this interface to provide or override the access modifier for a variable.
Accessor style defines the methods of a class that are automatically exposed via event property.
Represents the base expression for "first", "last" and "window" aggregation functions.
An Adapter takes some external data, converts it into events, and sends it
into the runtime.
An Adapter takes some external data, converts it into events, and sends it
into the runtime runtime.
The state of a Adapter.
A utility to manage the state transitions for an InputAdapter.
Maintains aggregation state applying values as entering and leaving the state.
Interface to implement for factories of aggregation functions.
Context for use with plug-in custom aggregation functions that implement
AggregationFunctionFactory.Compile-time representation of a plug-in aggregation function.
Describes to the compiler how it should manage code for the aggregation function.
Use this class to provide a fully code-generated aggregation function by implementing the internal
AggregatorMethodFactory interface.Use this class to provide an aggregation function wherein there is no need to write code that generates code,
wherein the aggregation function takes a single parameter and
wherein the compiler handles filtering and distinct.
Use this class to provide an aggregation function wherein there is no need to write code that generates code,
wherein the aggregation function takes a multiple parameters and
wherein the compiler does not handle filtering and distinct.
Context for use with plug-in custom aggregation functions that implement
AggregationFunctionForge.Accessor for access aggregation functions.
Factory for aggregation multi-function accessors.
Context for use with plug-in aggregation multi-functions that implement
AggregationMultiFunctionAccessorFactory.Describes to the compiler how it should manage code for aggregation multi-function accessors.
Use this class to provide an accessor wherein there is no need to write code that generates code,
Agents change mult-function aggregation state.
Factory for aggregation multi-function agents
Context for use with plug-in aggregation multi-functions that implement
AggregationMultiFunctionAgentFactory.Describes to the compiler how it should manage code for aggregation multi-function agents.
Use this class to provide an agent wherein there is no need to write code that generates code,
Aggregation method that operates on aggregation multi-function state such as provided by a multi-function aggregation (standalone or table column).
Context for use with plug-in aggregation multi-functions aggregation methods.
Factory for aggregation multi-function aggregation method
Context for use with plug-in aggregation multi-function that implement
AggregationMultiFunctionAggregationMethodFactory.Describes to the compiler how it should manage code for aggregation multi-function aggregation method.
Use this class to provide a aggregation method wherein there is no need to write code that generates code,
Context for use with
AggregationMultiFunctionForge provides
information about an aggregation function at the time of declaration.Entry point for the extension API for aggregation multi-functions.
Part of the aggregation multi-function extension API, this class represents
one of more aggregation function expression instances.
Aggregation multi-function return-type descriptor
Base interface for providing access-aggregations, i.e.
Factory for aggregation multi-function state
Context for use with plug-in aggregation multi-function that implement
AggregationMultiFunctionStateFactory.Marker interface for use with multi-function aggregation to indicate whether aggregation functions share state
Describes to the compiler how it should manage code for aggregation multi-function state factory.
Use this class to provide an state factory wherein there is no need to write code that generates code,
Context for use with
AggregationFunctionForge provides
information about an aggregation function at the time of validation.Represents a single annotation attribute, the value of which may itself be a single value, array or further annotations.
Represents a single annotation.
Annotation to target certain constructs.
Arithmatic expression for addition, subtraction, multiplication, division and modulo.
Array expression forms array results, similar to the syntax of "{element 1, element 2, ...
An assignment is an expression specifically for the purpose of usage in updates.
Annotation for use in EPL statements to add a debug.
Enumeration of audit values.
Mean deviation of the (distinct) values returned by an expression.
Average of the (distinct) values returned by an expression.
Annotation for use with Avro to provide a schema for a given event property.
Marker interface for conditions reported.
Between checks that a given value is in a range between a low endpoint and a high endpoint.
Bitwise (binary) operator for binary AND, binary OR and binary XOR.
List of built-in annotations.
Annotation that is the modifier for event-bus-visible event types
Provides the environment to
BusModifierEventTypeOption.Implement this interface to provide or override the bus modifier for an event type.
Enum indicating what kind of references are used to store the cache map's keys and values.
Case-expression that acts as a switch testing a value against other values.
Case expression that act as a when-then-else.
Cast expression casts the return value of an expression to a specified type.
Provider of lookup of a class name resolving into a class.
Default provider for classname lookups.
Provider of a classloader.
Default class loader provider returns the current thread context classloader.
Script-expression is external scripting language expression such as JavaScript, Groovy or MVEL, for example.
Coalesce-function which returns the first non-null value in a list of values.
Represents a list-compare of the format "expression operator all/any (expressions)".
Arguments holder for use with
EPCompiler.compile(java.lang.String, com.espertech.esper.compiler.client.CompilerArguments).Provides the environment to
CompilerHookOption.Implement this interface to provide a compiler to use
Callbacks and optional values for the compiler to determine modifiers, statement name,
statement user object, module name and module-uses.
The compiler uses the path to determine the EPL-objects available to the module.
For optional use with the compiler, for speeding up compilation when the compiler path has one or more
EPCompiled instances that provide visible EPL objects (named windows, tables etc.),
this cache retains and helps reuse the information in respect to each EPCompiled instance and the visible EPL objects it provides.Concatenation expression that concatenates the result of child expressions to the expression.
Interface for a handler registered with a runtime instance to receive reported runtime conditions.
Context provided to
ConditionHandler implementations providing
runtime-condition-contextual information.Factory for runtime condition handler instance(s).
Context provided to
ConditionHandlerFactory implementations providing
runtime contextual information.Indicates that on the runtimelevel the match-recognize has reached the configured runtime-wide limit at runtime.
Indicates that on the runtimelevel the followed-by pattern operator, regardless whether parameterized with a max number of sub-expressions or not,
has reached the configured runtime-wide limit at runtime.
Indicates that the followed-by pattern operator, when parameterized with a max number of sub-expressions,
has reached that limit at runtime.
An instance of
Configuration allows the application
to specify properties to be used when compiling and when getting a runtime.Contains settings that apply to both the compile-time and the runtime.
Marker interface for different cache settings.
Expiring cache settings.
LRU cache settings.
Container for database configuration information, such as
options around getting a database connection and options to control the lifecycle
of connections and set connection parameters.
Controls how output column names get reflected in the event type.
Marker for different connection factory settings.
Enum controlling connection lifecycle.
Supplies connection-level settings for a given database name.
Connection factory settings for using a DataSource.
Connection factory settings for using a Apache DBCP or other provider DataSource factory.
Connection factory settings for using a DriverManager.
Indicates how the runtime retrieves metadata about a statement's output columns.
Configuration for Avro event types.
Configuration information for legacy (non-JavaBean) event types.
Encapsulates information about an accessor field backing a named event property.
Encapsulates information about an accessor method backing a named event property.
Configuration information for JSON event types.
Configuration object for Map-based event types.
Event representation metadata.
Avro settings.
Configuration object for Object array-based event types.
Configuration object for event types with super-types and timestamp.
Configuration object for enabling the runtimeto process events represented as XML DOM document nodes.
Descriptor class for event properties that are resolved via XPath-expression.
Holds common execution-related settings.
Holds view logging settings other then the Apache commons or Log4J settings.
Holds configuration information for data caches for use in method invocations in the from-clause.
Parser for the common section of configuration.
Time source configuration, the default in MILLI (millisecond resolution from System.currentTimeMillis).
Provides variable configuration.
Configures a variant stream.
Enumeration specifying whether only the predefine types or any type of event is accepted by the variant stream.
Contains settings that apply to the compiler only (and that do not apply at runtime).
Code generation settings.
Holds execution-related settings.
Controls the level of planning of filter indexes from filter expressions.
Expression evaluation settings in the runtime are for results of expressions.
Language settings in the runtime are for string comparisons.
Holds view logging settings other then the Apache commons or Log4J settings.
Parser for the compiler section of configuration.
Configuration information for plugging in a custom aggregation function.
Configuration information for plugging in a custom aggregation multi-function.
Configuration information for plugging in a custom date-time-method.
Configuration information for plugging in a custom enum-method.
Configuration information for plugging in a custom view.
Configuration information for plugging in a custom single-row function.
Controls whether a single-row function is eligible for optimization if it occurs in a filter expression.
Enum for single-row function value cache setting.
Configuration information for plugging in a custom view.
Configuration information for plugging in a custom view.
Holder for script settings.
Serialization and Deserialization options.
Holds default settings for stream selection in the select-clause.
Holds view resources settings.
Thrown to indicate a configuration problem.
Contains settings that apply to the runtime only (and that do not apply to the compiler).
Configuration object for defining condition handling behavior.
Configuration object for defining exception handling behavior.
Holds runtime execution-related settings.
Expression evaluation settings in the runtime are for results of expressions.
Holds view logging settings other then the Apache commons or Log4J settings.
Holds match-recognize settings.
Configuration for metrics reporting.
Class to configure statement metrics reporting for a group of one or more statements.
Parser for the runtime section of configuration.
Holds pattern settings.
Holds configuration for a plugin such as an input/output adapter loader.
Holds threading settings.
Time source configuration, the default in MILLI (millisecond resolution from System.currentTimeMillis).
Holds variables settings.
Helper to migrate schema version 7 XML configuration to schema version 8 XML configuration.
Conjunction represents a logical AND allowing multiple sub-expressions to be connected by AND.
Constant value returns a fixed value for use in expressions.
Represents a contained-event selection.
Interface for context dimension descriptors.
Category-segmented context.
Context descriptor for categories.
For use with overlapping or non-overlapping contexts, implementations represents a condition for starting/initiating
or ending/terminating a context.
Context condition that start/initiated or ends/terminates context partitions based on a crontab expression.
Context condition that start/initiated or ends/terminates context partitions based on a filter expression.
Context condition that starts/initiates immediately.
Context condition that starts/initiates immediately.
Context condition that start/initiated or ends/terminates context partitions based on a pattern.
Context condition that start/initiated or ends/terminates context partitions based on a time period.
Hash-segmented context.
Context detail for a library-func and filter pair for the hash segmented context.
Context dimension descriptor for a start-and-end temporal (single instance) or initiated-terminated (overlapping) context
Context dimension information for keyed segmented context.
Context detail for a key-filter pair for the keyed segmented context.
Nested context.
A collection of context partitions each uniquely identified by a context partition id (agent instance id).
Context partition identifiers are provided by the API when interrogating context partitions for a given statement.
Context partition identifier for category context.
Context partition identifier for hash context.
Context partition identifier for overlapping and non-overlapping contexts.
Context partition identifier for nested contexts.
Context partition identifier for segmented contexts.
Interface for classes representing a selector for navigating, querying or selecting among context partitions.
Selects all context paritions.
Selects a context partition by providing the context partition id(s).
Selects context partitions for use with a category context by providing a set of labels.
Selects context partitions by receiving a context partition identifier for interrogation.
Selects context partitions based on hash codes, for use with hashed context.
Selects context partitions of a nested context by providing selector according to the nested contexts.
Selector of context partitions for use with segmented contexts, provides a set of partition keys to select.
Listener for context-specific partition-related events.
The variable state for a context partitioned variable.
Context state event.
Context state event indicating a context activated.
Context state event indicating a new context created.
Context state event indicating a context deactivated.
Context state event indicating a context destroyed.
Context partition state event.
Context partition state event indicating a context partition allocated.
Context partition state event indicating a context partition de-allocated.
Context partition state event indicating a statement added.
Context partition state event indicating a statement removed.
Listener for event in respect to context management.
Represents the "countever" aggregation function.
For use with Count-min sketch aggregation functions:
The agent implementation encapsulates transformation of value objects to byte-array and back (when needed),
and may override or provide custom behavior.
Count-min sketch base context object.
Count-min sketch context object for add-operations.
Count-min sketch context object for estimate-operations.
Count-min sketch context object for topk-operations.
For use with Count-min sketch aggregation functions:
The agent implementation encapsulates transformation of value objects to byte-array and back (when needed),
and may override or provide custom behavior.
Count-min sketch agent that handles String-type values and uses UTF-16 encoding
to transform strings to byte-array and back.
Count-min sketch agent that handles String-type values and uses UTF-16 encoding
to transform strings to byte-array and back.
Value object for count-min-sketch top-k.
Count of the (distinct) values returned by an expression, equivalent to "count(distinct property)"
Count of (distinct) rows, equivalent to "count(*)"
Clause for creating an application-provided class for use across one or more statements.
Create a context.
Represents a create-variable syntax for creating a new variable.
Clause for creating an expression for use across one or more statements.
Create an index on a named window.
Create an index on a named window.
Enumeration to represents the index type.
Represents a create-schema syntax for creating a new event type.
Represents a type definition for use with the create-schema syntax for creating a new event type.
Represents a create-variable syntax for creating a new variable.
Table column in a create-table statement.
Represents a create-variable syntax for creating a new variable.
Create a named window, defining the parameter of the named window such as window name and data window view name(s).
Frequency expression for use in crontab expressions.
Parameter expression such as last/lastweek/weekday/wildcard for use in crontab expressions.
An expression for use in crontab provides all child expression as part of a parameter list.
Parameter expression for use in crontab expressions and representing a range.
Current execution context supplies the current expression execution context.
Current timestamp supplies the current runtime time in an expression.
Data flow field-level annotation for the field that receives the dataflow context
Object model of a data flow operator declaration.
Represents an input port of an operator.
Represents an output port of an operator.
Represents type information for data flow operators.
Object model of a data flow operator parameter.
Annotation for use with data flow fields on operator forges to receive parameters
Annotation for use with data flow fields on operator forges to receive additional properties
Annotation for use with data flow forges to indicate signal handling
Utility for data flow parameter resolution that considers parameter providers that are passed in.
Utility for validation data flow forge parameters
Implementations read and write objects from/to the stream.
Collects an object from
DataInput and emits the object to an emitter.Context for use with
DataInputToObjectCollector carries data input and emitter.Reads a
Serializable from DataInput and emits the resulting object.Utility class for date-time functions.
Provides footprint information for date-time method extension.
Date-time method extension API for adding date-time methods.
Context for use with the date-time method extension API
Describes to the compiler how it should manage code for the date-time method.
Provides information about the public static method that implements the logic for the date-time method.
Interface for use with date-time method operations.
For adding a date-time method that modifies the date-time value and that return a result of the same type
as the date-time value.
For adding a date-time method that reformats the date-time value returning a result of a different type
as the date-time value.
Context for use with the date-time method extension API
Provides the environment to
DeploymentClassLoaderOption.Implement this interface to provide a custom class loader for a deployment.
Option holder for use with
EPDeploymentService.deploy(com.espertech.esper.common.client.EPCompiled).Deployment base event.
Deployment event indicating a deployment completed
Deployment event indicating a undeployment completed
Listener for events in respect to deployment and undeployment.
Annotation for use in EPL statements to add a description.
Disjunction represents a logical OR allowing multiple sub-expressions to be connected by OR.
Dot-expresson is for use in "(inner_expression).dot_expression".
Dot-expresson item is for use in "root_expression.dot_expression".
Dot-expresson item representing an array operation.
Dot-expresson item representing a call that has an name and parameters.
Dot-expresson item representing an identifier without parameters.
An execution directive for use in an EPL statement, that causes processing of an event to stop after the EPL statement
marked with @Drop has processed the event, applicable only if multiple statements must process the same event.
Provides footprint information for enumeration method extension.
Enumeration method extension API for adding enum-methods.
Context for use with the date-time method extension API
For use with lambda parameters, the descriptor identifies a specific lambda parameter.
Lambda parameter type defines what value "v" assumes in an expression such as
mymethod(v => ...),
or what value "a" or "b" assume in an expression such as mymethod( (a,b) => ...).A lambda parameter that assumes an index value.
A lambda parameter that assumes the size value.
A lambda parameter that assumes a value of the given type and that originates from the state object
by calling the provided getter-method.
A lambda parameter that assumes the value itself.
Describes to the compiler how it should manage code for the enumeration method.
Provides information about the public static method that implements the logic for the enumeration method.
Interface for state-providing classes for use with enumeration method extension
Context for use with the enumeration method extension API
Assertion methods for event processing applications.
Callback for extracting individual collection items for assertion.
Base class for named runtime objects such as views, patterns guards and observers.
The byte code and manifest of a compile EPL module or EPL fire-and-forget query.
IO-related utilized for
EPCompiledManifest is part of the
EPCompiled and provides information for the runtime that
allows it to use the byte code.Indicates an exception compiling a module or fire-and-forget query
Exception information.
Indicates a syntax exception
The EPL compiler compiles EPL text as well as object models to byte code.
Marker interface for an object containing information that can be added to the compiler path
Provides compiler instances.
Service interface for administration of contexts and context partitions.
Thrown to indicate a data flow saved configuration already exists.
Indicates cancellation of a data flow instance.
Data flow descriptor.
Emitter for use with data flow operators
Filter for use with the EPStatementSource operator.
Context object for filter for use with the EPStatementSource operator.
Collector for use with the EventBusSource operator.
For use with
EPDataFlowEventBeanCollector provides collection context.Collector for use with the EventBusSink operator.
For use with
EPDataFlowEventCollector provides collection context.Context for use with
EPDataFlowExceptionHandler.Handler for exceptions thrown by data flow operators.
Thrown to indicate a data flow execution exception.
Data flow instanve.
Holder for captive data flow execution.
Statistics holder for data flow instances.
Interface for statictics of data flow instance.
Indicates an exception instantiating a data flow.
Options for use when instantiating a data flow in
EPDataFlowService.Collector for use with the EPStatementSource operator.
Context for use with
EPDataFlowIRStreamCollector.Thrown to indicate a data flow is not found.
Handles setting or overriding properties for operators in a data flow.
Context for use with
EPDataFlowOperatorParameterProvider describes the operator and parameters to provide.For use in data flow instantiation, may provide operator instances.
Context for use with
EPDataFlowOperatorProvider.A data flow configuration is just a configuration name, a data flow name
and an instantiation options object.
Data flow runtime for instantiating data flows.
Base marker interface for data flow signals.
Final marker for data flows.
Window marker for data flows.
Data flow instance states.
Deploy exception to indicate that a deployment by the same deployment id already exists
Deploy exception to indicate that the compiler version mismatches
Exception during a deploy operation by
EPDeploymentService.deploy(com.espertech.esper.common.client.EPCompiled)Deploy exception to indicate a problem taking the necessary lock
Represents a deployment.
Provides information about EPL objects that a deployment consumes (requires, depends on, refers to) from other deployments.
Information about EPL objects consumed by another deployment.
Provides information about EPL objects that a deployment provides to other deployments.
Information about EPL Objects provided by the deployment
Contains the result of a rollout as described in
EPDeploymentService.rollout(Collection, RolloutOptions),
captures the rollout result wherein the deployment result of each compilation unit is provided by EPDeploymentRolloutItem.For use with rollout as described in
EPDeploymentService.rollout(Collection, RolloutOptions),
for passing a compilation unit and the deployment options for the compilation unit.The result item of a rollout as described in
EPDeploymentService.rollout(Collection, RolloutOptions),
captures the rollout result of a single compilation unit that was deployed as part of a rollout.Service for deploying and undeploying modules and obtaining information about current deployments and statements.
Deploy exception to indicate that a precondition is not satisfied
Deploy exception to indicate that substitution parameter values have not been provided
Service for processing events and advancing time.
Service for processing events that originate from listeners, subscribers or other extension code.
Service for processing events.
Service for advancing and controlling time.
Provider for rendering services of
EventBean events.Service for managing event types.
This exception is thrown to indicate a problem in administration and runtime.
Interface for a prepared on-demand query that can be executed multiple times.
Parameter holder for parameterized on-demand queries that are prepared with substitution parameters and that
can be executed efficiently multiple times with different actual values for parameters.
Result for fire-and-forget queries.
Executes fire-and-forget non-continuous on-demand queries against named windows or tables.
Interface to iterate over events.
Provides expression evaluation context information in an expression.
Interface to add and remove update listeners.
Invocation context for method invocations that invoke static methods or plug-in single-row functions.
Available when using JSR-223 scripts or MVEL, for access of script attributes.
Service for metrics reporting.
Represents a statement in the query API for statement metrics
Represents a statement group in the query API for statement metrics
EPL object type.
Provider for a re-compiler that acts on existing deployment to either re-compile or re-load from an external source
Context for use with
EPRecompileProviderException for use with
EPRecompileProviderProvider for rendering services of
EventBean events.The runtime for deploying and executing EPL.
This exception is thrown to indicate that the runtime instance has been destroyed.
Factory for instances of
EPRuntime.A listener interface for callbacks regarding
EPRuntime state changes.A stage allows staging and unstageing deployments, allowing independent control over event and time for the deployments.
Stage deployment service provides information about deployments staged to a given
EPStage.This exception is thrown to indicate that the runtime instance has been destroyed.
Stage event service for sending events and advancing time to a given
EPStage stage.Stage base exception.
Indicated a precondition is violated for a stage or un-stage operation.
Stages are used for staging deployments allowing independent control over event and time for subsets of deployments.
The statement is the means to attach callbacks to receive statement results (push, observer)
and to object current results using pull.
Object model of an EPL statement.
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.
EPType is the common superinterface for all types in EPL.EPTypeClass represents the value class and does not have type parameters.Provides type parameters.
EPTypeNull represents a null-type.Provides
EPType instances for common types.Exception during an undeploy operation by
EPDeploymentService.undeploy(java.lang.String)Undeploy exception to indicate a problem taking the necessary lock
Undeploy exception to indicate that the deployment was not found
Uneploy exception to indicate that a precondition is not satisfied
Service for variable management.
Interface for event representation.
Collated writer for events, intented for passing along as a parameter and not intended to be implemented by an application
Factory for
EventBean instances given an underlying event object.Descriptor for event property names, property types and access metadata.
Get property values from an event instance for a given event property.
Get property values from an event instance for a given indexed event property by passing the array index.
Get property values from an event instance for a given mapped event property by passing the map string key.
Interface for use with the JSON or XML event renderes to handle custom event property rendering.
Context for use with the
EventPropertyRenderer interface for use with the JSON or XML event renderes to handle custom event property rendering.Get property values from an event instance for a given event property.
Annotation that can be attached to specify which underlying event representation to use for events.
Returns a facility to process event objects that are of a known type.
Event sender for JSON documents and pre-parsed event objects.
This interface provides metadata on events.
Application type.
Modifier that dictates whether an event type allows or does not allow sending events in using one of the send-event
methods.
Indicates that a problem occurred looking up, assigning or creating and event type.
Pair of public and protected event type id.
Provides metadata for an event type.
Metatype.
Enumeration of event representation.
Interface for an exception handler.
Context provided to
ExceptionHandler implementations providing
exception-contextual information as well as the exception itself.Context provided to
ExceptionHandler implementations providing
exception-contextual information as well as the exception itself,
for use with inbound pools and for exceptions unassociated to statements when using inbound pools.Indicates the phase during which and exception was encountered.
Factory for exception handler instance(s).
Context provided to
ExceptionHandlerFactory implementations providing
runtime contextual information.Extends the
ExceptionHandler with a method to, for the inbound-pool threading configuration,
handle exceptions that are not associated to a specific statement i.e.Exception for line item.
Interface for exceptions that have a line items
Interface representing an expression for use in select-clauses, where-clauses, having-clauses, order-by clauses and
streams based on filters and pattern filter expressions.
Base expression.
Represents a single expression declaration that applies to a given statement.
For use in expression as a placeholder to represent its child nodes.
Precendence levels for expressions.
Convenience factory for creating
Expression instances.Annotation for use in EPL statements to add a debug.
Annotation for use in EPL statements to add a debug.
Annotation for use in EPL statements with inline classes for providing a plug-in single-row function.
Filter defines the event type to be filtered for, and an optional expression that returns true if
the filter should consider the event, or false to reject the event.
Filter service profile.
A stream upon which projections (views) can be added that selects events by name and filter expression.
Marker interface used for fire-and-forget (on-demand) queries such as "update...set" and "delete from..."
that can be executed via the API.
Fire-and-forget (on-demand) delete DML.
Fire-and-forget (on-demand) insert DML.
Fire-and-forget (on-demand) update DML.
Represents the "firstever" aggregation function.
Represents the "first" aggregation function.
A for-clause is a means to specify listener and observer delivery.
An item in a for-clause for controlling delivery of result events to listeners and subscribers.
Keywords for use in the for-clause.
Provides an event type for a property of an event.
The from-clause names the streams to select upon.
The group-by clause consists of a list of expressions that provide the grouped-by values.
Base interface for group-by clause expressions, covers all possible combinations
of expressions, parenthesis-expression-combinations, rollup, cube and grouping sets
and their parameters.
A combination of expressions is for example "(a, b)", wherein the list of expressions provided
together logically make up a grouping level.
Represents the "grouping sets" keywords.
Represents a rollup or cube in a group-by clause.
Represents a single expression (non-combined, rollup/cube or grouping set) as part of a group-by expression.
Grouping-function for use with rollup, cube or grouping sets.
Grouping_id-function for use with rollup, cube or grouping sets.
Enum for all build-in guards.
Multi-key made up of multiple values providing hashcode and equals semantics using
Object.hashCode() and Arrays.equals(Object[], Object[])Annotation for providing a statement execution hint.
Enumeration of hint values.
Use this annotation to install a statement-specific hook or callback at time of statement creation.
Enumeration for the different types of statement-processing hooks (callbacks) that can be provided for a statement.
Thrown when an illegal Adapter state transition is attempted.
In-expresson checks that a value is in (or not in) a set of values, equivalent to the syntax "color in ('red', 'blue')".
Interface for providing the compiler with code that allocates and initializes an instance of some class
Provides the compiler with code that allocates and initializes an instance of some class
by using "new" and by using setters.
Provides the environment to
InlinedClassInspectionOption.Implement this interface to receive Janino-specific class detail for inlined-classes.
An InputAdapter takes some external data, converts it into events, and sends it into the runtime runtime.
An insert-into clause consists of a stream name and column names and an optional stream selector.
Instance-of expression checks if an expression returns a certain type.
Into-table clause.
Indicates an invalid combination of context declaration and context partition selector, i.e.
Returns true for insert stream and false for remove stream, same as the "istream()" builtin function.
Annotation for use in EPL statements for making an unbound stream iterable returning the last event without
requiring a data window to be declared.
This class serves as the entry point to the minimal-json API.
Represents a JSON array, an ordered collection of JSON values.
Annotation for use with Json to provide an adapter for a given class field.
All JSON underlying event objects implement this interface.
Renderer for an event into the JSON textual format.
JSON event renderer
JSON field adapter.
JSON field adapter for strings.
A handler for parser events.
JSON number.
Represents a JSON object, a set of name/value pairs, where the names are strings and the values
are JSON values.
A streaming parser for JSON text.
JSON rendering options.
Annotation for use with JSON schemas.
Annotation for use with Json to provide an adapter for a given event property name.
Represents a JSON value.
Base junction for conjunction (and) and disjunction (or).
Lambda-expression is an expression of the form "parameter => body" where-in the "=>" reads as goes-to.
Represents the "lastever" aggregation function.
Represents the "last" aggregation function.
SQL-Like expression for matching '%' and '_' wildcard strings following SQL standards.
An immutable object that represents a location in the parsed text.
Enumeration of blocking techniques.
Implement this interface to provide a custom deployment lock strategy.
Obtains the write lock of the runtime-wide event processing read-write lock by simply blocking until the lock was obtained.
Exception for use with
LockStrategy.Obtains the write lock of the runtime-wide event processing read-write lock by simply blocking until the lock was obtained.
Obtains the write lock of the runtime-wide event processing read-write lock by trying the lock
waiting for the timeout and throwing an exception if the lock was not taken.
Enum for match recognize pattern atom types.
Match-recognize clause.
Define-clause in match-recognize expression.
Interval used within match recognize.
Interface representing an expression for use in match-recognize.
Interface representing an expression for use in match-recognize.
Atom representing an expression for use in match-recognize.
Interface representing an expression for use in match-recognize.
Atom representing an expression for use in match-recognize.
Interface representing a permutation expression for use in match-recognize.
For use in match recognize pattern expression as a placeholder to represent its child nodes.
Match-recognize pattern descriptor for repetition
Skip clause enum for match recognize.
Maximum of the (distinct) values returned by an expression.
Maximum-value per-row expression (not aggregating) determines the maximum value among a set of values.
Median projection (aggregation) in the distinct and regular form.
Represents a member of a JSON object, a pair of a name and a value.
An stream that polls from a method.
Base metric event.
Minimum of the (distinct) values returned by an expression.
Minimum-value per-row expression (not aggregating) determines the minimum value among a set of values.
Represent a deployment unit consisting of deployment declarative information (module name, uses and imports)
as well as EPL statements represented by
ModuleItem.Represents an EPL statement as part of a
Module.Provides the environment to
ModuleNameOption.Implement this interface to provide or override the module name at compile-time.
Holds an ordered list of modules considering each module's uses-dependencies on other modules.
Exception indicates a problem when determining delpoyment order and uses-dependency checking.
Options class passed to #getModuleOrder(java.util.Collection, ModuleOrderOptions)} for controlling the behavior of ordering and dependency checking logic.
Module ordering utility.
Provides well-known module properties.
Provides the environment to
ModuleUsesOption.Implement this interface to provide or override the module-uses at compile-time.
Interface for use with multi-keys made up of multiple values and providing hashcode and equals semantics
Annotation for use in EPL statement to define a statement name.
Visibility modifiers for EPL objects.
Named parameter expression of the form "name:expression" or "name:(expression, expression...)"
The "new instance" operator instantiates a host language object.
The "new" operator is useful to format an event or event property from a list of column names and expressions.
Annotation for use in EPL statements to suppress any statement-level locking (use with caution, see below).
Negates the contained-within subexpression.
Receives an object and writes to
DataOutput.Context for use with
ObjectToDataOutputCollector carries object and data output.Writes a
Serializable object to DataOutput.For Avro use widener or transformer of object values to Avro record values
For Avro types for widening objects to Avro record values, see
ObjectValueTypeWidenerFactoryA clause to delete from a named window based on a triggering event arriving and correlated to the named window events to be deleted.
A clause to delete from a named window based on a triggering event arriving and correlated to the named window events to be deleted.
A clause to insert into zero, one or more streams based on criteria.
Items within the split-stream syntax to contain a tuple of insert-into, select and where-clause.
A clause to insert, update or delete to/from a named window based on a triggering event arriving and correlated to the named window events to be updated.
Marker interface for an on-merge clause action item.
For use with on-merge clauses, deletes from a named window if matching rows are found.
For use with on-merge clauses, inserts into a named window if matching rows are not found.
For use with on-merge clauses, updates rows in a named window if matching rows are found.
As part of on-merge, this represents a single "matched" or "not matched" entry.
A clause to delete from a named window based on a triggering event arriving and correlated to the named window events to be deleted.
A clause to assign new values to variables based on a triggering event arriving.
A clause to update a named window based on a triggering event arriving and correlated to the named window events to be updated.
An order-by clause consists of expressions and flags indicating if ascending or descending.
A single entry in an order-by clause consisting of an expression and order ascending or descending flag.
For use in view parameter lists, this is a wrapper expression
that adds an ascending or descending sort indicator to its single child expression.
Qualifies a join by providing the outer join type (full/left/right) and joined-on properties.
An output limit clause defines how to limit output of statements and consists of
a selector specifiying which events to select to output, a frequency and a unit.
Selector for use in output rate limiting.
Unit for output rate limiting.
Annotation for use with data flow operator forges to provide output type information
Annotation for use with data flow operator forges to provide output type information
An unchecked exception to indicate that an input does not qualify as valid JSON.
Exception thrown when an EPL text could not be parsed.
Logical AND for use in pattern expressions.
Every-Distinct construct for use in pattern expressions.
Pattern 'every' expression that controls the lifecycle of pattern sub-expressions.
Interface representing a pattern expression.
Abstract base class for all pattern expressions.
For use in pattern expression as a placeholder to represent its child nodes.
Pattern precendences.
Filter for use in pattern expressions.
Followed-by for use in pattern expressions.
Guard is the where timer-within pattern object for use in pattern expressions.
Match-Until construct for use in pattern expressions.
Not-expression for negating a pattern sub-expression for use in pattern expressions.
Choice for type of pattern object.
Pattern observer expression observes occurances such as timer-at (crontab) and timer-interval.
Logical OR for use in pattern expressions.
Convenience factory for creating
PatternExpr instances, which represent pattern expression trees.A stream of events that is generated by pattern matches.
Interface for loaders of input/output adapters or any other adapter that may participate in a runtime lifecycle.
Context for plugin initialization.
Represents a plug-in aggregation function.
Enables human readable JSON output by inserting whitespace between values.after commas and
colons.
Previous function for obtaining property values of previous events.
Previous function type.
Expression representing the prior function.
An execution directive for use in an EPL statement, by which processing of an event by statements
start with the statement that has the highest priority, applicable only if multiple statements must process the same event.
Annotation that is the public access modifier
Abstract base class for streams that can be projected via views providing data window, uniqueness or other projections
or deriving further information from streams.
This exception is thrown to indicate a problem with a accessing a property of an
EventBean.Property-exists checks if a dynamic property exists.
Enumeration of different resolution styles for resolving property names.
Expression returning a property value.
Pair of expressions with "equals" operator between.
Annotation that is the public access modifier
Annotation that is the public access modifier
Regular expression evaluates a "regexp" regular expression.
Comparison using one of the relational operators (=, !=, <, <=, >, >=, is, is not).
Option holder for use with
EPDeploymentService.rollout(java.util.Collection<com.espertech.esper.runtime.client.EPDeploymentRolloutCompiled>) ()}.Specification object for a row limit.
Reports runtime-level instrumentation values.
Runtime version.
A concurrency-safe iterator that iterates over events representing statement results (pull API)
in the face of concurrent event processing by further threads.
Type of schedule item.
Descriptor for use in create-schema syntax to define property name and type of an event property.
Helper for asserting conditions.
Script-expression is external scripting language expression such as JavaScript, Groovy or MVEL, for example.
A select-clause consists of a list of selection elements (expressions, wildcard(s), stream wildcard and the like)
and an optional stream selector.
Item in a select-clause to describe individual select-clause expressions or wildcard(s).
Part of a select-clause to describe individual select-clause expressions.
For use in a select clause, this element in a select clause defines that for a given stream we want to
select the underlying type.
Represents a wildcard in the select-clause.
For use with high-availability and scale-out only, provider for serde (serializer and deserializer) information
to the compiler.
For use with high-availability and scale-out only, this class provides additional information passed to serde provider, for use with
SerdeProviderInformation that the serde applies to an aggregation.
Information that the serde applies to an distinct-value expression of an aggregation.
Information that the serde applies to a derived-value view property.
Information about the event property for which to obtain a serde.
Information about the event type for which to obtain a serde.
Information that the serde applies to a filter.
Information that the serde applies to an index.
Information about the multikey for which to obtain a serde.
Information about the variable for which to obtain a serde.
For use with high-availability and scale-out only, this class provides contextual information about the class that we
looking to serialize or de-serialize, for use with
SerdeProviderFor use with high-availability and scale-out only, this class provides contextual information about the event type that we
looking to serialize or de-serialize, for use with
SerdeProviderFactory for serde providers.
Context provided to serde provider factories for runtime-contextual information.
For use with high-availability and scale-out only, this class provides information to the compiler how to
resolve the serializer and de-serializer (serde) at deployment-time.
For use with high-availability and scale-out only, this class instructs the compiler that the serializer and de-serializer (serde)
is available for a given component type and component type serde
For use with high-availability and scale-out only, this class instructs the compiler that the serializer and de-serializer (serde)
is available via a singleton-pattern-style static field named "INSTANCE" (preferred) or by has a default constructor.
For use with high-availability and scale-out only, this class instructs the compiler that the serializer and de-serializer (serde)
is available using a parameterized constructor that accepts expressions as represents by the functions provided.
Generic single-row method call consists of a method name and parameters, possibly chained.
For use with
SQLColumnTypeConversion, context of column conversion.Implement this interface when providing a callback for SQL input parameter and column result processing for a statement,
converting an input parameter or converting an output column value into any other value.
For use with
SQLColumnTypeConversion, context of column conversion.For use with
SQLColumnTypeConversion, context of parameter conversion.Implement this interface when providing a callback for SQL row result processing for a statement,
converting each row's values into a POJO.
For use with
SQLOutputRowConversion, context of row conversion.For use with
SQLOutputRowConversion, context of row conversion.An SQL stream that polls via SQL for events via join.
Reports statement-level instrumentation values.
Provides the environment to
StatementNameOption.Implement this interface to provide a custom user object at compile-time for the statements when they are compiled.
Provides the environment to
StatementNameRuntimeOption.Implement this interface to provide a statement name at runtime for statements when they are deployed.
Base class providing statement information for compiler options.
Provides well-known statement properties.
Provides the environment to
StatementSubstitutionParameterOption.Implement this interface to provide values for substitution parameters.
Type of the statement.
Provides the environment to
StatementUserObjectOption.Implement this interface to provide a custom user object at compile-time for the statements when they are compiled.
Provides the environment to
StatementUserObjectRuntimeOption.Implement this interface to provide a custom user object at runtime for statements when they are deployed.
For internal-use-only and subject-to-change-between-versions: Provides the environment to
StateMgmtSettingOption.Implement this interface to provide or override the state management settings, for use with high-availability only.
Static method call consists of a class name and method name.
Standard deviation of the (distinct) values returned by an expression.
An abstract base class for a named or unnamed stream.
Enumeration for representing selection of the remove stream or the insert stream, or both.
Represents "stream.*" in for example "mystream.*"
Exists-expression for a set of values returned by a lookup.
Subquery-expression returns values returned by a lookup modelled by a further
EPStatementObjectModel.In-expression for a set of values returned by a lookup.
Exists-expression for a set of values returned by a lookup.
Represents a substitution parameter
Sum of the (distinct) values returned by an expression.
Listener interface for use in regression testing for asserting receive events.
Subscriber for that retains the events it receives for use in assertions.
Subscriber for multi-row delivery that retains the events it receives for use in assertions.
Update listener that retains the events it receives for use in assertions.
Table access expression.
Annotation for use in EPL statement to tag a statement with a name-value pair.
Threading profile.
Represents a time period.
Represent an expression
Time source type.
Type-of expression return the type name, as a string value, of the events in the stream if passing a stream name or
the fragment event type if passing a property name that results in a fragment event otherwise
the class simple name of the expression result or null if the expression returns a null value.
For Avro schemas for mapping a given type to a given Avro schema.
For Avro customized type mapping, use with
TypeRepresentationMapperOption holder for use with
EPDeploymentService.undeploy(java.lang.String).Enumeration of blocking techniques.
Interface to receive notification from an runtime that an event that has been sent into the runtimeor that
has been generated via insert-into has not been matched to any statement, considering all started statement's
event stream filter criteria (not considering where-clause and having-clauses).
Specification for the update clause.
Defines an interface to notify of new and old events.
Indicates that a variable cannot be set.
Indicates that a variable was not found.
Indicates that a variable value could not be assigned.
A view provides a projection upon a stream, such as a data window, grouping or unique.
A virtual data window exposes externally-managed data transparently as a named window without the need
to retain any data in memory.
Context for use with virtual data window factory
VirtualDataWindowFactory provides
contextual information about the named window and the type of events held,
handle for posting insert and remove streams and factory for event bean instances.Base class for events related to virtual data windows.
Event indicating a named-window consuming statement is being added.
Base class for events indicating a named-window consumer management.
Event indicating a named-window consuming statement is being removed.
Event raised when an index gets created or started via the "create index" syntax.
Captures virtual data window indexed field information.
Event to indicate that for a virtual data window an exitsing index is being stopped or destroyed.
This event is raised when a virtual data window is stopped.
Factory for virtual data windows.
Context for use with virtual data window factory
VirtualDataWindowFactory provides
contextual information as well as the handle for posting insert and remove streams and factory for event bean instances.A factory that the runtime invokes at deployment time to obtain the virtual data window factory.
Context for use with a virtual data window factory factory
VirtualDataWindowFactoryFactory.Describes to the compiler how it should manage code for the virtual data window factory.
Use this class to provide a virtual data window factory wherein there is no need to write code that generates code.
Factory for
VirtualDataWindow.Context for use with virtual data window forge
VirtualDataWindowForge provides
contextual information about the named window and the type of events held.Provides a range as a start and end value, for use as a paramater to the lookup values passed to the
VirtualDataWindowLookup lookup method.Represents a lookup strategy object that an EPL statement that queries a virtual data window obtains
to perform read operations into the virtual data window.
Context passed to
VirtualDataWindow upon obtaining a lookup strategy for use by an EPL statement
that queries the virtual data window.As part of a lookup context, see
VirtualDataWindowLookupContext, this object encapsulates information about a single
property in a correlated where-clause.Enumeration for indicating the type of operator for a lookup against a virtual data window, see
VirtualDataWindowLookupContext.For use with virtual data windows, handles any insert stream and remove stream events that a
virtual data window may post to consuming statements.
Represents "*" in for example "last(*)"
Represents the "window" aggregation function.
Controls the formatting of the JSON output.
A lightweight writing buffer to reduce the amount of write operations to be performed on the
underlying writer.
Renderer for an event into the XML textual format.
XML rendering options.
Annotation for use with XML schemas.
Annotation for use with XML to set a given event property name to use XPath.
Annotation for use with XML schemas to define a namespace prefix.