com.espertech.esper.filter

Class FilterSpecCompiler

java.lang.Object

com.espertech.esper.filter.FilterSpecCompiler

public final class FilterSpecCompiler
extends Object

Helper to compile (validate and optimize) filter expressions as used in pattern and filter-based streams.

Field Summary

Fields

Modifier and Type	Field and Description
static String	PROPERTY_NAME_BOOLEAN_EXPRESSION Assigned for filter parameters that are based on boolean expression and not on any particular property name.

Constructor Summary

Constructors

Constructor and Description
FilterSpecCompiler()

Method Summary

Modifier and Type	Method and Description
static FilterSpecCompiled	build(List<ExprNode> validatedNodes, EventType eventType, String eventTypeName, PropertyEvalSpec optionalPropertyEvalSpec, LinkedHashMap<String,Pair<EventType,String>> taggedEventTypes, LinkedHashMap<String,Pair<EventType,String>> arrayEventTypes, StreamTypeService streamTypeService, String optionalStreamName, StatementContext stmtContext, Collection<Integer> assignedTypeNumberStack)
static FilterSpecCompiled	buildNoStmtCtx(List<ExprNode> validatedFilterNodes, EventType eventType, String eventTypeName, PropertyEvalSpec optionalPropertyEvalSpec, LinkedHashMap<String,Pair<EventType,String>> taggedEventTypes, LinkedHashMap<String,Pair<EventType,String>> arrayEventTypes, StreamTypeService streamTypeService, String optionalStreamName, Collection<Integer> assignedTypeNumberStack, ExprEvaluatorContext exprEvaluatorContext, int statementId, String statementName, Annotation[] annotations, ContextDescriptor contextDescriptor, EngineImportService engineImportService, EventAdapterService eventAdapterService, FilterBooleanExpressionFactory filterBooleanExpressionFactory, TimeProvider timeProvider, VariableService variableService, TableService tableService, ConfigurationInformation configurationInformation, NamedWindowMgmtService namedWindowMgmtService, StatementExtensionSvcContext statementExtensionSvcContext)
static FilterSpecCompiled	makeFilterSpec(EventType eventType, String eventTypeName, List<ExprNode> filterExpessions, PropertyEvalSpec optionalPropertyEvalSpec, LinkedHashMap<String,Pair<EventType,String>> taggedEventTypes, LinkedHashMap<String,Pair<EventType,String>> arrayEventTypes, StreamTypeService streamTypeService, String optionalStreamName, StatementContext statementContext, Collection<Integer> assignedTypeNumberStack) Factory method for compiling filter expressions into a filter specification for use with filter service.
static List<ExprNode>	validateAllowSubquery(ExprNodeOrigin exprNodeOrigin, List<ExprNode> exprNodes, StreamTypeService streamTypeService, StatementContext statementContext, LinkedHashMap<String,Pair<EventType,String>> taggedEventTypes, LinkedHashMap<String,Pair<EventType,String>> arrayEventTypes) Validates expression nodes and returns a list of validated nodes.

Methods inherited from class java.lang.Object

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

Field Detail

PROPERTY_NAME_BOOLEAN_EXPRESSION

public static final String PROPERTY_NAME_BOOLEAN_EXPRESSION

Assigned for filter parameters that are based on boolean expression and not on any particular property name.

Keeping this artificial property name is a simplification as optimized filter parameters generally keep a property name.

See Also:

Constant Field Values

Constructor Detail

FilterSpecCompiler

public FilterSpecCompiler()

Method Detail

makeFilterSpec

public static FilterSpecCompiled makeFilterSpec(EventType eventType,
                                                String eventTypeName,
                                                List<ExprNode> filterExpessions,
                                                PropertyEvalSpec optionalPropertyEvalSpec,
                                                LinkedHashMap<String,Pair<EventType,String>> taggedEventTypes,
                                                LinkedHashMap<String,Pair<EventType,String>> arrayEventTypes,
                                                StreamTypeService streamTypeService,
                                                String optionalStreamName,
                                                StatementContext statementContext,
                                                Collection<Integer> assignedTypeNumberStack)
                                         throws ExprValidationException

Factory method for compiling filter expressions into a filter specification for use with filter service.

Parameters:

eventType - is the filtered-out event type

eventTypeName - is the name of the event type

filterExpessions - is a list of filter expressions

taggedEventTypes - is a map of stream names (tags) and event types available

arrayEventTypes - is a map of name tags and event type per tag for repeat-expressions that generate an array of events

streamTypeService - is used to set rules for resolving properties

optionalStreamName - - the stream name, if provided

optionalPropertyEvalSpec - - specification for evaluating properties

statementContext - context for statement

assignedTypeNumberStack - type numbers assigned

Returns:

compiled filter specification

Throws:

ExprValidationException - if the expression or type validations failed

build

public static FilterSpecCompiled build(List<ExprNode> validatedNodes,
                                       EventType eventType,
                                       String eventTypeName,
                                       PropertyEvalSpec optionalPropertyEvalSpec,
                                       LinkedHashMap<String,Pair<EventType,String>> taggedEventTypes,
                                       LinkedHashMap<String,Pair<EventType,String>> arrayEventTypes,
                                       StreamTypeService streamTypeService,
                                       String optionalStreamName,
                                       StatementContext stmtContext,
                                       Collection<Integer> assignedTypeNumberStack)
                                throws ExprValidationException

Throws:

ExprValidationException

buildNoStmtCtx

public static FilterSpecCompiled buildNoStmtCtx(List<ExprNode> validatedFilterNodes,
                                                EventType eventType,
                                                String eventTypeName,
                                                PropertyEvalSpec optionalPropertyEvalSpec,
                                                LinkedHashMap<String,Pair<EventType,String>> taggedEventTypes,
                                                LinkedHashMap<String,Pair<EventType,String>> arrayEventTypes,
                                                StreamTypeService streamTypeService,
                                                String optionalStreamName,
                                                Collection<Integer> assignedTypeNumberStack,
                                                ExprEvaluatorContext exprEvaluatorContext,
                                                int statementId,
                                                String statementName,
                                                Annotation[] annotations,
                                                ContextDescriptor contextDescriptor,
                                                EngineImportService engineImportService,
                                                EventAdapterService eventAdapterService,
                                                FilterBooleanExpressionFactory filterBooleanExpressionFactory,
                                                TimeProvider timeProvider,
                                                VariableService variableService,
                                                TableService tableService,
                                                ConfigurationInformation configurationInformation,
                                                NamedWindowMgmtService namedWindowMgmtService,
                                                StatementExtensionSvcContext statementExtensionSvcContext)
                                         throws ExprValidationException

Throws:

ExprValidationException

validateAllowSubquery

public static List<ExprNode> validateAllowSubquery(ExprNodeOrigin exprNodeOrigin,
                                                   List<ExprNode> exprNodes,
                                                   StreamTypeService streamTypeService,
                                                   StatementContext statementContext,
                                                   LinkedHashMap<String,Pair<EventType,String>> taggedEventTypes,
                                                   LinkedHashMap<String,Pair<EventType,String>> arrayEventTypes)
                                            throws ExprValidationException

Validates expression nodes and returns a list of validated nodes.

Parameters:

exprNodes - is the nodes to validate

streamTypeService - is provding type information for each stream

taggedEventTypes - pattern tagged types

arrayEventTypes - event types that provide array values

statementContext - context

exprNodeOrigin - origin

Returns:

list of validated expression nodes

Throws:

ExprValidationException - for validation errors