com.espertech.esper.epl.core
Class SelectExprProcessorFactory

java.lang.Object
  com.espertech.esper.epl.core.SelectExprProcessorFactory

public class SelectExprProcessorFactory
extends java.lang.Object

Factory for select expression processors.

Nested Class Summary

static class

SelectExprProcessorFactory.SelectExprBuckets

Constructor Summary

SelectExprProcessorFactory()

Method Summary

static SelectExprProcessor

getProcessor(java.util.Collection<java.lang.Integer> assignedTypeNumberStack, SelectClauseElementCompiled[] selectionList, boolean isUsingWildcard, InsertIntoDesc insertIntoDesc, EventType optionalInsertIntoEventType, ForClauseSpec forClauseSpec, StreamTypeService typeService, EventAdapterService eventAdapterService, StatementResultService statementResultService, ValueAddEventService valueAddEventService, SelectExprEventTypeRegistry selectExprEventTypeRegistry, MethodResolutionService methodResolutionService, ExprEvaluatorContext exprEvaluatorContext, VariableService variableService, TableService tableService, TimeProvider timeProvider, java.lang.String engineURI, java.lang.String statementId, java.lang.String statementName, java.lang.annotation.Annotation[] annotations, ContextDescriptor contextDescriptor, ConfigurationInformation configuration, SelectExprProcessorDeliveryCallback selectExprProcessorCallback, NamedWindowService namedWindowService, IntoTableSpec intoTableClause) Returns the processor to use for a given select-clause.

protected static void

verifyNameUniqueness(SelectClauseElementCompiled[] selectionList) Verify that each given name occurs exactly one.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SelectExprProcessorFactory

public SelectExprProcessorFactory()

Method Detail

getProcessor

public static SelectExprProcessor getProcessor(java.util.Collection<java.lang.Integer> assignedTypeNumberStack,
                                               SelectClauseElementCompiled[] selectionList,
                                               boolean isUsingWildcard,
                                               InsertIntoDesc insertIntoDesc,
                                               EventType optionalInsertIntoEventType,
                                               ForClauseSpec forClauseSpec,
                                               StreamTypeService typeService,
                                               EventAdapterService eventAdapterService,
                                               StatementResultService statementResultService,
                                               ValueAddEventService valueAddEventService,
                                               SelectExprEventTypeRegistry selectExprEventTypeRegistry,
                                               MethodResolutionService methodResolutionService,
                                               ExprEvaluatorContext exprEvaluatorContext,
                                               VariableService variableService,
                                               TableService tableService,
                                               TimeProvider timeProvider,
                                               java.lang.String engineURI,
                                               java.lang.String statementId,
                                               java.lang.String statementName,
                                               java.lang.annotation.Annotation[] annotations,
                                               ContextDescriptor contextDescriptor,
                                               ConfigurationInformation configuration,
                                               SelectExprProcessorDeliveryCallback selectExprProcessorCallback,
                                               NamedWindowService namedWindowService,
                                               IntoTableSpec intoTableClause)
                                        throws ExprValidationException

Returns the processor to use for a given select-clause.

Parameters:

selectionList - - the list of select clause elements/items, which are expected to have been validated

isUsingWildcard - - true if the wildcard (*) occurs in the select clause

insertIntoDesc - - contains column names for the optional insert-into clause (if supplied)

typeService - - serves stream type information

eventAdapterService - - for generating wrapper instances for events

statementResultService - handles listeners/subscriptions awareness to reduce output result generation

valueAddEventService - - service that handles update events and variant events

selectExprEventTypeRegistry - - registry for event type to statements

methodResolutionService - - for resolving write methods

exprEvaluatorContext - context for expression evalauation

Returns:

select-clause expression processor

Throws:

ExprValidationException - to indicate the select expression cannot be validated

verifyNameUniqueness

protected static void verifyNameUniqueness(SelectClauseElementCompiled[] selectionList)
                                    throws ExprValidationException

Verify that each given name occurs exactly one.

Parameters:

selectionList - is the list of select items to verify names

Throws:

ExprValidationException - thrown if a name occured more then once