com.espertech.esper.core.service.speccompiled

Class StreamSpecCompiler

java.lang.Object

com.espertech.esper.core.service.speccompiled.StreamSpecCompiler

public class StreamSpecCompiler
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	StreamSpecCompiler.FilterForFilterFactoryNodes

Constructor Summary

Constructors

Constructor and Description
StreamSpecCompiler()

Method Summary

Modifier and Type	Method and Description
static StreamSpecCompiled	compile(FilterStreamSpecRaw streamSpec, StatementContext context, java.util.Set<java.lang.String> eventTypeReferences, boolean isInsertInto, java.util.Collection<java.lang.Integer> assignedTypeNumberStack, boolean isJoin, boolean isContextDeclaration, boolean isOnTrigger, java.lang.String optionalStreamName)
static StreamSpecCompiled	compile(MethodStreamSpec methodStreamSpec)
static PatternStreamSpecCompiled	compile(PatternStreamSpecRaw streamSpecRaw, StatementContext context, java.util.Set<java.lang.String> eventTypeReferences, boolean isInsertInto, java.util.Collection<java.lang.Integer> assignedTypeNumberStack, boolean isJoin, boolean isContextDeclaration, boolean isOnTrigger, java.lang.String optionalStreamName)
static PatternStreamSpecCompiled	compile(PatternStreamSpecRaw streamSpecRaw, StatementContext context, java.util.Set<java.lang.String> eventTypeReferences, boolean isInsertInto, java.util.Collection<java.lang.Integer> assignedTypeNumberStack, MatchEventSpec priorTags, java.util.Set<java.lang.String> priorAllTags, boolean isJoin, boolean isContextDeclaration, boolean isOnTrigger)
static StreamSpecCompiled	compile(StreamSpecRaw spec, StatementContext statementContext, java.util.Set<java.lang.String> eventTypeReferences, boolean isInsertInto, java.util.Collection<java.lang.Integer> assignedTypeNumberStack, boolean isJoin, boolean isContextDeclaration, boolean isOnTrigger, java.lang.String optionalStreamName) Compiles a raw stream specification consisting event type information and filter expressions to an validated, optimized form for use with filter service
static EventType	resolveType(java.lang.String engineURI, java.lang.String eventName, EventAdapterService eventAdapterService, java.net.URI[] optionalResolutionURIs) Resolves a given event name to an event type.

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamSpecCompiler

public StreamSpecCompiler()

Method Detail

compile

public static StreamSpecCompiled compile(StreamSpecRaw spec,
                                         StatementContext statementContext,
                                         java.util.Set<java.lang.String> eventTypeReferences,
                                         boolean isInsertInto,
                                         java.util.Collection<java.lang.Integer> assignedTypeNumberStack,
                                         boolean isJoin,
                                         boolean isContextDeclaration,
                                         boolean isOnTrigger,
                                         java.lang.String optionalStreamName)
                                  throws ExprValidationException

Compiles a raw stream specification consisting event type information and filter expressions to an validated, optimized form for use with filter service

Parameters:

spec - spec

statementContext - statement-level services

eventTypeReferences - event type names used by the statement

isInsertInto - true for insert-into

isJoin - indicates whether a join or not a join

isContextDeclaration - indicates whether declared as part of the context declarations, if any

isOnTrigger - indicator for on-trigger

optionalStreamName - stream name

assignedTypeNumberStack - for assigning nested type numbers

Returns:

compiled stream

Throws:

ExprValidationException - to indicate validation errors

compile

public static StreamSpecCompiled compile(FilterStreamSpecRaw streamSpec,
                                         StatementContext context,
                                         java.util.Set<java.lang.String> eventTypeReferences,
                                         boolean isInsertInto,
                                         java.util.Collection<java.lang.Integer> assignedTypeNumberStack,
                                         boolean isJoin,
                                         boolean isContextDeclaration,
                                         boolean isOnTrigger,
                                         java.lang.String optionalStreamName)
                                  throws ExprValidationException

Throws:

ExprValidationException

resolveType

public static EventType resolveType(java.lang.String engineURI,
                                    java.lang.String eventName,
                                    EventAdapterService eventAdapterService,
                                    java.net.URI[] optionalResolutionURIs)
                             throws ExprValidationException

Resolves a given event name to an event type.

Parameters:

eventName - is the name to resolve

eventAdapterService - for resolving event types

engineURI - the provider URI

optionalResolutionURIs - is URIs for resolving the event name against plug-inn event representations, if any

Returns:

event type

Throws:

ExprValidationException - if the info cannot be resolved

compile

public static PatternStreamSpecCompiled compile(PatternStreamSpecRaw streamSpecRaw,
                                                StatementContext context,
                                                java.util.Set<java.lang.String> eventTypeReferences,
                                                boolean isInsertInto,
                                                java.util.Collection<java.lang.Integer> assignedTypeNumberStack,
                                                boolean isJoin,
                                                boolean isContextDeclaration,
                                                boolean isOnTrigger,
                                                java.lang.String optionalStreamName)
                                         throws ExprValidationException

Throws:

ExprValidationException

compile

public static PatternStreamSpecCompiled compile(PatternStreamSpecRaw streamSpecRaw,
                                                StatementContext context,
                                                java.util.Set<java.lang.String> eventTypeReferences,
                                                boolean isInsertInto,
                                                java.util.Collection<java.lang.Integer> assignedTypeNumberStack,
                                                MatchEventSpec priorTags,
                                                java.util.Set<java.lang.String> priorAllTags,
                                                boolean isJoin,
                                                boolean isContextDeclaration,
                                                boolean isOnTrigger)
                                         throws ExprValidationException

Throws:

ExprValidationException

compile

public static StreamSpecCompiled compile(MethodStreamSpec methodStreamSpec)
                                  throws ExprValidationException

Throws:

ExprValidationException