com.espertech.esper.event.vaevent
Class ValueAddEventServiceImpl

java.lang.Object
  extended by com.espertech.esper.event.vaevent.ValueAddEventServiceImpl
All Implemented Interfaces:
ValueAddEventService

public class ValueAddEventServiceImpl
extends Object
implements ValueAddEventService

Service for handling revision event types.

Each named window instance gets a dedicated revision processor.


Constructor Summary
ValueAddEventServiceImpl()
          Ctor.
 
Method Summary
 void addRevisionEventType(String revisionEventTypeAlias, ConfigurationRevisionEventType config, EventAdapterService eventAdapterService)
          Adds a new revision event types.
 void addVariantStream(String variantStreamname, ConfigurationVariantStream variantStreamConfig, EventAdapterService eventAdapterService)
          Adds a new variant stream.
 EventType createRevisionType(String namedWindowName, String alias, StatementStopService statementStopService, EventAdapterService eventAdapterService)
          Upon named window creation, create a unique revision event type that this window processes.
 ValueAddEventProcessor getValueAddProcessor(String alias)
          Gets a value-added event processor.
 EventType getValueAddUnderlyingType(String alias)
          Upon named window creation, and during resolution of type specified as part of a named window create statement, returns looks up the revision event type alias provided and return the revision event type if found, or null if not found.
 void init(Map<String,ConfigurationRevisionEventType> configRevision, Map<String,ConfigurationVariantStream> configVariant, EventAdapterService eventAdapterService)
          Called at initialization time, verifies configurations provided.
 boolean isRevisionTypeAlias(String revisionTypeAlias)
          Upon named window creation, check if the alias used is a revision event type alias.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ValueAddEventServiceImpl

public ValueAddEventServiceImpl()
Ctor.

Method Detail

init

public void init(Map<String,ConfigurationRevisionEventType> configRevision,
                 Map<String,ConfigurationVariantStream> configVariant,
                 EventAdapterService eventAdapterService)
          throws ConfigurationException
Description copied from interface: ValueAddEventService
Called at initialization time, verifies configurations provided.

Specified by:
init in interface ValueAddEventService
Parameters:
configRevision - is the revision types to add
configVariant - is the variant streams to add
eventAdapterService - for obtaining event type information for each alias
Throws:
ConfigurationException

addRevisionEventType

public void addRevisionEventType(String revisionEventTypeAlias,
                                 ConfigurationRevisionEventType config,
                                 EventAdapterService eventAdapterService)
                          throws ConfigurationException
Description copied from interface: ValueAddEventService
Adds a new revision event types.

Specified by:
addRevisionEventType in interface ValueAddEventService
Parameters:
revisionEventTypeAlias - to add
config - the revision event type configuration
eventAdapterService - for obtaining event type information for each alias
Throws:
ConfigurationException

addVariantStream

public void addVariantStream(String variantStreamname,
                             ConfigurationVariantStream variantStreamConfig,
                             EventAdapterService eventAdapterService)
                      throws ConfigurationException
Description copied from interface: ValueAddEventService
Adds a new variant stream.

Specified by:
addVariantStream in interface ValueAddEventService
Parameters:
variantStreamname - the alias of the type
variantStreamConfig - the configs
eventAdapterService - for handling nested events
Throws:
ConfigurationException - if the configuration is invalid

createRevisionType

public EventType createRevisionType(String namedWindowName,
                                    String alias,
                                    StatementStopService statementStopService,
                                    EventAdapterService eventAdapterService)
Description copied from interface: ValueAddEventService
Upon named window creation, create a unique revision event type that this window processes.

Specified by:
createRevisionType in interface ValueAddEventService
Parameters:
namedWindowName - name of window
alias - alias to use
statementStopService - for handling stops
eventAdapterService - for event type info
Returns:
revision event type

getValueAddProcessor

public ValueAddEventProcessor getValueAddProcessor(String alias)
Description copied from interface: ValueAddEventService
Gets a value-added event processor.

Specified by:
getValueAddProcessor in interface ValueAddEventService
Parameters:
alias - of the value-add events
Returns:
processor

getValueAddUnderlyingType

public EventType getValueAddUnderlyingType(String alias)
Description copied from interface: ValueAddEventService
Upon named window creation, and during resolution of type specified as part of a named window create statement, returns looks up the revision event type alias provided and return the revision event type if found, or null if not found.

Specified by:
getValueAddUnderlyingType in interface ValueAddEventService
Parameters:
alias - to look up
Returns:
null if not found, of event type

isRevisionTypeAlias

public boolean isRevisionTypeAlias(String revisionTypeAlias)
Description copied from interface: ValueAddEventService
Upon named window creation, check if the alias used is a revision event type alias.

Specified by:
isRevisionTypeAlias in interface ValueAddEventService
Parameters:
revisionTypeAlias - to check
Returns:
true if revision event type, false if not

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