All Classes and Interfaces
Class
Description
An abstract base class for all reporter implementations which periodically poll registered
metrics (e.g., to send the data to another service).
The base class for all metric reporters.
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.
An abstraction for how time passes.
A clock implementation which returns the current thread's CPU time.
A clock implementation which returns the current time in epoch nanoseconds.
A simple reporters which prints out application metrics to a
PrintStream periodically.An incrementing and decrementing counter metric.
A reporter which periodically appends data from each metric to a metric-specific CSV file in
an output directory.
The context used to output metrics.
A
HealthCheck implementation which returns a list of deadlocked threads, if any.
When a thread throws an Exception that was not caught, a DeathRattleExceptionHandler will
increment a counter signalling a thread has died and print out the name and stack trace of the
thread.
Converts a row of column selection results into a result for dispatch to a method.
Converts column results into a Map of key-value pairs.
Implementation that does not convert columns.
Implementation that does not convert columns.
Implementation of a convertor for column results that renders the result as an object array itself.
Implementation of a convertor for column results that renders the result as an object array itself.
Implementation of a convertor for column results that renders the result as an object array itself.
Implementation of a convertor for column results that renders the result as an object array itself.
Implementation that does not convert columns.
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.
Comparator for DoubleRange values.
Thread factory for threading options.
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.
Implements runtime interface.
Service for processing events that originate from listeners, subscribers or other extension code.
Service for processing events.
Service for advancing and controlling time.
Service for managing event types.
Executes fire-and-forget non-continuous on-demand queries against named windows or tables.
Interface to iterate over events.
Interface to add and remove update listeners.
EPL object type.
Provides prepared query functionality.
Query result.
The runtime for deploying and executing EPL.
This exception is thrown to indicate that the runtime instance has been destroyed.
Service provider encapsulates the runtime's services for runtime and administration interfaces.
Factory for instances of
EPRuntime.A listener interface for callbacks regarding
EPRuntime state changes.Interface for a factory class to provide services in a services context for an runtime instance.
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.
Provides update listeners for use by statement instances, and the management methods around these.
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.
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
Interface for matching an event instance based on the event's property values to
filters, specifically filter parameter constants or ranges.
Mapping of event type to a tree-like structure
containing filter parameter constants in indexes
FilterParamIndexBase and filter callbacks in FilterHandleSetNode.This class is responsible for changes to
EventTypeIndex for addition and removal of filters.An exponentially-weighted moving average.
An exponentially-decaying random sample of
longs.This class holds a list of indizes storing filter constants in
FilterParamIndexBase nodes
and a set of FilterHandle.Each implementation of this abstract class represents an index of filter parameter constants supplied in filter
parameters in filter specifications that feature the same event property and operator.
Index that simply maintains a list of boolean expressions.
Index for filter parameter constants for the comparison operators (less, greater, etc).
Index for filter parameter constants for the comparison operators (less, greater, etc).
Index for filter parameter constants for the range operators (range open/closed/half).
Index for filter parameter constants for the range operators (range open/closed/half).
Index for filter parameter constants for the not range operators (range open/closed/half).
Index for filter parameter constants to match using the equals (=) operator.
Index for filter parameter constants to match using the equals (=) operator.
Index for filter parameter constants to match using the equals (=) operator.
Index for filter parameter constants to match using the 'in' operator to match against a supplied set of values
(i.e.
Each implementation of this abstract class represents an index of filter parameter constants supplied in filter
parameters in filter specifications that feature the same event property and operator.
Index for filter parameter constants to match using the equals (=) operator.
Index for filter parameter constants to match using the equals (=) operator.
Index for filter parameter constants to match using the equals (=) operator.
Index for filter parameter constants to match using the 'not in' operator to match against a
all other values then the supplied set of values.
Index for filter parameter constants to match using the equals (=) operator.
Index for filter parameter constants for the range operators (range open/closed/half).
Index for filter parameter constants for the not range operators (range open/closed/half).
Implementation of the filter service interface.
Listener to filter activity.
Service provider interface for filter service.
Holder object for a set of filters for one or more statements.
Entry to a
FilterSet filter set taken from a FilterService.A gauge metric is an instantaneous reading of a particular value.
A health check for a component of your application.
The result of a
HealthCheck being run.A registry for health checks.
A manager class for health checks.
A metric which calculates the distribution of a value.
Thrown when an illegal Adapter state transition is attempted.
Interface for inbound runnables.
Inbound work unit processing a map event.
Inbound unit for DOM events.
Inbound unit for unwrapped events.
Inbound work unit processing a json event.
Inbound work unit processing a map event.
Inbound work unit processing a map event.
Inbound unit for wrapped events.
Factory for
FilterParamIndexBase instances based on event property name and filter operator type.Utility class for matching filter parameters to indizes.
An InputAdapter takes some external data, converts it into events, and sends it into the runtime runtime.
A gauge which exposes an attribute of a JMX MBean.
Mark the annotated class for management via JMX.
Mark the given method as accessible from JMX.
Mark the given parameter as accessible from JMX.
A reporter which exposes application metric as JMX MBeans.
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.
A meter metric which measures mean throughput and one-, five-, and fifteen-minute
exponentially-weighted moving average throughputs.
An object which maintains mean and exponentially-weighted rate.
A tag interface to indicate that a class is a metric.
A value class encapsulating a metric's owning class and name.
A
MetricPredicate is used to determine whether a metric should be included when sorting
and filtering metrics.A processor of metric instances.
Metrics reporting.
SPI for metrics activity.
A set of factory methods for creating centrally registered metric instances.
A registry of metric instances.
Listeners for events from the registry.
Interface for statement result callbacks.
This service hold for each named window a dedicated processor and a lock to the named window.
Singleton class for testing out multi-threaded code.
Outbound unit.
A
RatioGauge extension which returns a percentage, not a ratio.Interface for loaders of input/output adapters or any other adapter that may participate in a runtime lifecycle.
Context for plugin initialization.
A gauge which measures the ratio of one value to another.
Strategy for use with statement-result-service to dispatch to a statement's subscriber
via method invocations.
Factory for creating a dispatch strategy based on the subscriber object
and the columns produced by a select-clause.
A result delivery strategy that uses a matching "update" method and
optional start, end, and updateRStream methods, to deliver column-wise to parameters
of the update method.
A result delivery strategy that uses an "update" method that accepts a pair of map array.
A result delivery strategy that uses an "update" method that accepts a pair of object array array.
A result delivery strategy that uses an "update" method that accepts a pair of object array array.
A result delivery strategy that uses an "update" method that accepts a underlying array
for use in wildcard selection.
Option holder for use with
EPDeploymentService.rollout(java.util.Collection<com.espertech.esper.runtime.client.EPDeploymentRolloutCompiled>) ()}.Route execution work unit.
Route execution work unit.
Interface for route execution work units.
Route unit for single match.
Route unit for single match.
Implements a JNDI context for providing a directory for runtime-external resources such as adapters.
Runtime version.
Implements the safe iterator.
Implements the safe iterator.
A statistically representative sample of a data stream.
An object which samples values.
This exception is thrown to indicate a problem with schedule parameters.
Entry for a schedule item.
Implements the schedule service by simply keeping a sorted set of long millisecond
values and a set of handles for each.
Service provider interface for scheduling service.
A statistical snapshot of a
Snapshot.Event indicating statement lifecycle management.
Event types.
Observer statement management events.
Provides the environment to
StatementNameRuntimeOption.Implement this interface to provide a statement name at runtime for statements when they are deployed.
Implements tracking of statement listeners and subscribers for a given statement
such as to efficiently dispatch in situations where 0, 1 or more listeners
are attached and/or 0 or 1 subscriber (such as iteration-only statement).
Provides the environment to
StatementSubstitutionParameterOption.Implement this interface to provide values for substitution parameters.
Provides the environment to
StatementUserObjectRuntimeOption.Implement this interface to provide a custom user object at runtime for statements when they are deployed.
Interface for
Metric instances that can be stopped.Comparator for DoubleRange values.
An object which can produce statistical summaries.
A Double-typed value as a filter parameter representing a range.
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.
Engine-level threading services.
Implementation for runtime-level threading.
A timer metric which aggregates timing durations and provides duration statistics, plus
throughput statistics via
Meter.Callback interface for a time provider that triggers at scheduled intervals.
A timing context.
Service interface for repeated callbacks at regular intervals.
Implementation of the internal clocking service interface.
Timer processing unit.
Timer unit for multiple callbacks for a statement.
Timer unit for multiple callbacks for a statement.
Timer unit for a single callback for a statement.
Timer unit for a single callback for a statement.
Allow for different strategies for getting VM (wall clock) time.
Returns a
1 the first time it's called, a 0 every time after that.Option holder for use with
EPDeploymentService.undeploy(java.lang.String).A random sample of a stream of
longs.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).
Implements the iterator with table evaluation concern.
UpdateDispatchFutureSpin can be added to a dispatch queue that is thread-local.
UpdateDispatchFutureWait can be added to a dispatch queue that is thread-local.
Convenience view for dispatching view updates received from a parent view to update listeners
via the dispatch service.
Convenience view for dispatching view updates received from a parent view to update listeners
via the dispatch service.
Convenience view for dispatching view updates received from a parent view to update listeners
via the dispatch service.
Convenience view for dispatching view updates received from a parent view to update listeners
via the dispatch service.
Defines an interface to notify of new and old events.
A collection of Java Virtual Machine metrics.
Per-GC statistics.