com.espertech.esper.epl.spec
Class FilterStreamSpecRaw

java.lang.Object
  extended by com.espertech.esper.epl.spec.StreamSpecBase
      extended by com.espertech.esper.epl.spec.FilterStreamSpecRaw
All Implemented Interfaces:
StreamSpec, StreamSpecRaw, MetaDefItem, Serializable

public class FilterStreamSpecRaw
extends StreamSpecBase
implements StreamSpecRaw, MetaDefItem

Unvalided filter-based stream specification.

See Also:
Serialized Form

Constructor Summary
FilterStreamSpecRaw()
          Default ctor.
FilterStreamSpecRaw(FilterSpecRaw rawFilterSpec, List<ViewSpec> viewSpecs, String optionalStreamName, boolean isUnidirectional)
          Ctor.
 
Method Summary
 StreamSpecCompiled compile(EventAdapterService eventAdapterService, MethodResolutionService methodResolutionService, PatternObjectResolutionService patternObjectResolutionService, TimeProvider timeProvider, NamedWindowService namedWindowService, ValueAddEventService valueAddEventService, VariableService variableService, String engineURI, URI[] optionalPlugInTypeResolutionURIS)
          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.
protected static EventType resolveType(String engineURI, String eventName, EventAdapterService eventAdapterService, URI[] optionalResolutionURIs)
          Resolves a given event alias to an event type.
 
Methods inherited from class com.espertech.esper.epl.spec.StreamSpecBase
getOptionalStreamName, getViewSpecs, isUnidirectional
 
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, getViewSpecs, isUnidirectional
 

Constructor Detail

FilterStreamSpecRaw

public FilterStreamSpecRaw(FilterSpecRaw rawFilterSpec,
                           List<ViewSpec> viewSpecs,
                           String optionalStreamName,
                           boolean isUnidirectional)
Ctor.

Parameters:
rawFilterSpec - is unvalidated filter specification
viewSpecs - is the view definition
optionalStreamName - is the stream name if supplied, or null if not supplied
isUnidirectional - - true to indicate a unidirectional stream in a join, applicable for joins

FilterStreamSpecRaw

public FilterStreamSpecRaw()
Default ctor.

Method Detail

getRawFilterSpec

public FilterSpecRaw getRawFilterSpec()
Returns the unvalided filter spec.

Returns:
filter def

compile

public StreamSpecCompiled compile(EventAdapterService eventAdapterService,
                                  MethodResolutionService methodResolutionService,
                                  PatternObjectResolutionService patternObjectResolutionService,
                                  TimeProvider timeProvider,
                                  NamedWindowService namedWindowService,
                                  ValueAddEventService valueAddEventService,
                                  VariableService variableService,
                                  String engineURI,
                                  URI[] optionalPlugInTypeResolutionURIS)
                           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:
eventAdapterService - supplies type information
methodResolutionService - for resolving imports
patternObjectResolutionService - for resolving pattern objects
timeProvider - - provides engine current time
namedWindowService - is the service managing named windows
valueAddEventService - service that handles update events
variableService - provides variable values
engineURI - the engine URI
optionalPlugInTypeResolutionURIS - is URIs for resolving the event name against plug-inn event representations, if any
Returns:
compiled stream
Throws:
ExprValidationException - to indicate validation errors

resolveType

protected static EventType resolveType(String engineURI,
                                       String eventName,
                                       EventAdapterService eventAdapterService,
                                       URI[] optionalResolutionURIs)
                                throws ExprValidationException
Resolves a given event alias to an event type.

Parameters:
eventName - is the alias 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

© 2007 EsperTech Inc.
All rights reserved.
Visit us at espertech.com