com.espertech.esper.epl.spec

Class FilterStreamSpecRaw

java.lang.Object

com.espertech.esper.epl.spec.StreamSpecBase

com.espertech.esper.epl.spec.FilterStreamSpecRaw

All Implemented Interfaces:

StreamSpec, StreamSpecRaw, MetaDefItem, Serializable

public class FilterStreamSpecRaw
extends StreamSpecBase
implements StreamSpecRaw, MetaDefItem, Serializable

Unvalided filter-based stream specification.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
FilterStreamSpecRaw() Default ctor.
FilterStreamSpecRaw(FilterSpecRaw rawFilterSpec, ViewSpec[] viewSpecs, String optionalStreamName, StreamSpecOptions streamSpecOptions) Ctor.

Method Summary

Modifier and Type	Method and Description
StreamSpecCompiled	compile(StatementContext context, Set<String> eventTypeReferences, boolean isInsertInto, Collection<Integer> assignedTypeNumberStack, boolean isJoin, boolean isContextDeclaration, boolean isOnTrigger, String optionalStreamName) Compiles a raw stream specification consisting event type information and filter expressions to an validated, optimized form for use with filter service
FilterSpecRaw	getRawFilterSpec() Returns the unvalided filter spec.
static EventType	resolveType(String engineURI, String eventName, EventAdapterService eventAdapterService, URI[] optionalResolutionURIs) Resolves a given event name to an event type.

Methods inherited from class com.espertech.esper.epl.spec.StreamSpecBase

getOptionalStreamName, getOptions, getViewSpecs

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.espertech.esper.epl.spec.StreamSpec

getOptionalStreamName, getOptions, getViewSpecs

Constructor Detail

FilterStreamSpecRaw

public FilterStreamSpecRaw(FilterSpecRaw rawFilterSpec,
                           ViewSpec[] viewSpecs,
                           String optionalStreamName,
                           StreamSpecOptions streamSpecOptions)

Ctor.

Parameters:

rawFilterSpec - is unvalidated filter specification

viewSpecs - is the view definition

optionalStreamName - is the stream name if supplied, or null if not supplied

streamSpecOptions - - additional options, such as unidirectional stream in a join

FilterStreamSpecRaw

public FilterStreamSpecRaw()

Default ctor.

Method Detail

getRawFilterSpec

public FilterSpecRaw getRawFilterSpec()

Returns the unvalided filter spec.

Returns:

filter def

compile

public StreamSpecCompiled compile(StatementContext context,
                                  Set<String> eventTypeReferences,
                                  boolean isInsertInto,
                                  Collection<Integer> assignedTypeNumberStack,
                                  boolean isJoin,
                                  boolean isContextDeclaration,
                                  boolean isOnTrigger,
                                  String optionalStreamName)
                           throws ExprValidationException

Description copied from interface: StreamSpecRaw

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

Specified by:

compile in interface StreamSpecRaw

Parameters:

context - statement-level services

eventTypeReferences - event type names used by the statement

isInsertInto - true for insert-into

assignedTypeNumberStack - for assigning nested type numbers

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

Returns:

compiled stream

Throws:

ExprValidationException - to indicate validation errors

resolveType

public static EventType resolveType(String engineURI,
                                    String eventName,
                                    EventAdapterService eventAdapterService,
                                    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