Classes
Class | Description | |||||||||||||||||
---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
![]() | AggregationServiceBase |
All aggregation services require evaluation nodes which supply the value to
be aggregated (summed, averaged, etc.) and aggregation state factories to make
new aggregation states.
| ||||||||||||||||
![]() | AggregationServiceFactory |
Factory for aggregation service instances.
| ||||||||||||||||
![]() | AggregationServiceGroupAllImpl |
Implementation for handling aggregation without any grouping (no group-by).
| ||||||||||||||||
![]() | AggregationServiceGroupByImpl |
Implementation for handling aggregation with grouping by group-keys.
| ||||||||||||||||
![]() | AggregationServiceNull | A null object implementation of the AggregationService
interface.
| ||||||||||||||||
![]() | AliasNodeSwapper | A utility class for replacing select-clause aliases with their
definitions in expression node trees.
| ||||||||||||||||
![]() | AutoImportServiceImpl |
A service that allows users to refer to classes by partial names.
| ||||||||||||||||
![]() | DuplicatePropertyException | Indicates a property exists in multiple streams. | ||||||||||||||||
![]() | OrderByProcessorFactory |
Factory for net.esper.eql.core.OrderByProcessor processors.
| ||||||||||||||||
![]() | OrderByProcessorSimple |
An order-by processor that sorts events according to the expressions
in the order_by clause.
| ||||||||||||||||
![]() | PropertyNotFoundException | Exception to indicate that a property name used in a filter doesn't resolve. | ||||||||||||||||
![]() | PropertyResolutionDescriptor | Encapsulates the result of resolving a property and optional stream name against a supplied list of streams
net.esper.eql.core.StreamTypeService.
| ||||||||||||||||
![]() | ResultSetProcessorAggregateAll |
Result set processor for the case: aggregation functions used in the select clause, and no group-by,
and not all of the properties in the select clause are under an aggregation function.
This processor does not perform grouping, every event entering and leaving is in the same group.
The processor generates one row for each event entering (new event) and one row for each event leaving (old event).
Aggregation state is simply one row holding all the state.
| ||||||||||||||||
![]() | ResultSetProcessorAggregateGrouped |
Result-set processor for the aggregate-grouped case:
there is a group-by and one or more non-aggregation event properties in the select clause are not listed in the group by,
and there are aggregation functions.
This processor does perform grouping by computing MultiKey group-by keys for each row.
The processor generates one row for each event entering (new event) and one row for each event leaving (old event).
Aggregation state is a table of rows held by ${AggregationService} where the row key is the group-by MultiKey.
| ||||||||||||||||
![]() | ResultSetProcessorFactory |
Factory for output processors. Output processors process the result set of a join or of a view
and apply aggregation/grouping, having and some output limiting logic.
The instance produced by the factory depends on the presence of aggregation functions in the select list, the presence and nature of the group-by clause. In case (1) and (2) there are no aggregation functions in the select clause. Case (3) is without group-by and with aggregation functions and without non-aggregated properties in the select list:
Case (4) is without group-by and with aggregation functions but with non-aggregated properties in the select list:
Case (5) is with group-by and with aggregation functions and all selected properties are grouped-by. in the select list:
Case (6) is with group-by and with aggregation functions and only some selected properties are grouped-by. in the select list:
| ||||||||||||||||
![]() | ResultSetProcessorRowForAll |
Result set processor for the case: aggregation functions used in the select clause, and no group-by,
and all properties in the select clause are under an aggregation function.
This processor does not perform grouping, every event entering and leaving is in the same group. Produces one old event and one new event row every time either at least one old or new event is received. Aggregation state is simply one row holding all the state. | ||||||||||||||||
![]() | ResultSetProcessorRowPerGroup | Result set processor for the fully-grouped case:
there is a group-by and all non-aggregation event properties in the select clause are listed in the group by,
and there are aggregation functions.
Produces one row for each group that changed (and not one row per event). Computes MultiKey group-by keys for each event and uses a set of the group-by keys to generate the result rows, using the first (old or new, anyone) event for each distinct group-by key. | ||||||||||||||||
![]() | ResultSetProcessorSimple |
Result set processor for the simplest case: no aggregation functions used
in the select clause, and no group-by.
The processor generates one row for each event entering (new event) and one row for each event leaving (old event). | ||||||||||||||||
![]() | SelectExprEvalProcessor |
Processor for select-clause expressions that handles a list of selection items
represented by expression nodes. Computes results based on matching events.
| ||||||||||||||||
![]() | SelectExprJoinWildcardProcessor |
Processor for select-clause expressions that handles wildcards. Computes results based on matching events.
| ||||||||||||||||
![]() | SelectExprProcessorFactory |
Factory for select expression processors.
| ||||||||||||||||
![]() | StreamNotFoundException | Exception to indicate that a stream name could not be resolved. | ||||||||||||||||
![]() | StreamTypeServiceImpl |
Implementation that provides stream number and property type information.
| ||||||||||||||||
![]() | StreamTypesException | Base class for stream and property name resolution errors. | ||||||||||||||||
![]() | UniqueValueAggregator | Aggregator for use on top of another aggregator that handles unique value aggregation (versus all-value aggregation)
for the underlying aggregator.
|
Interfaces
Interface | Description | |
---|---|---|
![]() | AggregationResultFuture |
Interface for use by aggregate expression nodes representing aggregate functions such as 'sum' or 'avg' to use
to obtain the current value for the function at time of expression evaluation.
|
![]() | AggregationService |
Service for maintaing aggregation state. Processes events entering (a window, a join etc,) and
events leaving. Answers questions about current aggrataion state for a given row.
|
![]() | Aggregator | Maintains aggregation state applying values as entering and leaving the state.
Implementations must also act as a factory for further independent copies of aggregation states such that new aggregation state holders and be created from a prototype. |
![]() | AutoImportService |
Interface for a service that resolves a class name to type instances.
Implementations typically allow some sort of configuration on which
namespaces are automatically checked for presence of a type.
|
![]() | OrderByProcessor | A processor for ordering output events according to the order
specified in the order-by clause.
|
![]() | ResultSetProcessor | Processor for result sets coming from 2 sources. First, out of a simple view (on join).
And second, out of a join of event streams. The processor must apply the select-clause, grou-by-clause and having-clauses
as supplied. It must state what the event type of the result rows is.
|
![]() | SelectExprProcessor | Interface for processors of select-clause items, implementors are computing results based on matching events. |
![]() | StreamTypeService |
Service supplying stream number and property type information.
|