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	Coordinates between view factories and requested resource (by expressions) the availability of view resources to expressions.

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.