Package net.esper.eql.core

Contains EQL statement specification classes define the constructs that make up an EQL statement, such as the list of items in the select clause, the insert-into stream name and property names etc.

See:
          Description

Interface Summary
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.
Aggregator Maintains aggregation state applying values as entering and leaving the state.
AutoImportService Interface for a service that resolves a class name to Java Class instances.
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.
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.
ViewResourceCallback Callback for use by expression nodes to receive view resources.
ViewResourceDelegate Service to expression nodes for indicating view resource requirements.
 

Class Summary
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.
OrderByProcessorFactory Factory for OrderByProcessor processors.
OrderByProcessorSimple An order-by processor that sorts events according to the expressions in the order_by clause.
PropertyResolutionDescriptor Encapsulates the result of resolving a property and optional stream name against a supplied list of streams 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.
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.
ResultSetProcessorFactory Factory for output processors.
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.
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.
ResultSetProcessorSimple Result set processor for the simplest case: no aggregation functions used in the select clause, and no group-by.
SelectExprEvalProcessor Processor for select-clause expressions that handles a list of selection items represented by expression nodes.
SelectExprJoinWildcardProcessor Processor for select-clause expressions that handles wildcards.
SelectExprProcessorFactory Factory for select expression processors.
StreamTypeServiceImpl Implementation that provides stream number and property type information.
UniqueValueAggregator Aggregator for use on top of another aggregator that handles unique value aggregation (versus all-value aggregation) for the underlying aggregator.
ViewResourceDelegateImpl  
 

Exception Summary
DuplicatePropertyException Indicates a property exists in multiple streams.
PropertyNotFoundException Exception to indicate that a property name used in a filter doesn't resolve.
StreamNotFoundException Exception to indicate that a stream name could not be resolved.
StreamTypesException Base class for stream and property name resolution errors.
 

Package net.esper.eql.core Description

Contains EQL statement specification classes define the constructs that make up an EQL statement, such as the list of items in the select clause, the insert-into stream name and property names etc.