com.espertech.esper.event.vaevent
Interface ValueAddEventService

All Known Implementing Classes:

ValueAddEventServiceImpl

public interface ValueAddEventService

Service associating handling vaue-added event types, such a revision event types and variant stream event types.

Associates named windows and revision event types.

Method Summary

void	addRevisionEventType(java.lang.String name, ConfigurationRevisionEventType config, EventAdapterService eventAdapterService) Adds a new revision event types.
void	addVariantStream(java.lang.String variantEventTypeName, ConfigurationVariantStream variantStreamConfig, EventAdapterService eventAdapterService, EventTypeIdGenerator eventTypeIdGenerator) Adds a new variant stream.
EventType	createRevisionType(java.lang.String namedWindowName, java.lang.String typeName, StatementStopService statementStopService, EventAdapterService eventAdapterService, EventTypeIdGenerator eventTypeIdGenerator) Upon named window creation, create a unique revision event type that this window processes.
EventType[]	getValueAddedTypes() Returns all event types representing value-add event types.
ValueAddEventProcessor	getValueAddProcessor(java.lang.String name) Gets a value-added event processor.
EventType	getValueAddUnderlyingType(java.lang.String name) 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 name provided and return the revision event type if found, or null if not found.
void	init(java.util.Map<java.lang.String,ConfigurationRevisionEventType> revisionTypes, java.util.Map<java.lang.String,ConfigurationVariantStream> variantStreams, EventAdapterService eventAdapterService, EventTypeIdGenerator eventTypeIdGenerator) Called at initialization time, verifies configurations provided.
boolean	isRevisionTypeName(java.lang.String name) Upon named window creation, check if the name used is a revision event type name.

Method Detail

init

void init(java.util.Map<java.lang.String,ConfigurationRevisionEventType> revisionTypes,
          java.util.Map<java.lang.String,ConfigurationVariantStream> variantStreams,
          EventAdapterService eventAdapterService,
          EventTypeIdGenerator eventTypeIdGenerator)

Called at initialization time, verifies configurations provided.

Parameters:

revisionTypes - is the revision types to add

variantStreams - is the variant streams to add

eventAdapterService - for obtaining event type information for each name

addRevisionEventType

void addRevisionEventType(java.lang.String name,
                          ConfigurationRevisionEventType config,
                          EventAdapterService eventAdapterService)

Adds a new revision event types.

Parameters:

name - to add

config - the revision event type configuration

eventAdapterService - for obtaining event type information for each name

addVariantStream

void addVariantStream(java.lang.String variantEventTypeName,
                      ConfigurationVariantStream variantStreamConfig,
                      EventAdapterService eventAdapterService,
                      EventTypeIdGenerator eventTypeIdGenerator)
                      throws ConfigurationException

Adds a new variant stream.

Parameters:

variantEventTypeName - the name of the type

variantStreamConfig - the configs

eventAdapterService - for handling nested events

Throws:

ConfigurationException - if the configuration is invalid

getValueAddUnderlyingType

EventType getValueAddUnderlyingType(java.lang.String name)

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 name provided and return the revision event type if found, or null if not found.

Parameters:

name - to look up

Returns:

null if not found, of event type

createRevisionType

EventType createRevisionType(java.lang.String namedWindowName,
                             java.lang.String typeName,
                             StatementStopService statementStopService,
                             EventAdapterService eventAdapterService,
                             EventTypeIdGenerator eventTypeIdGenerator)

Upon named window creation, create a unique revision event type that this window processes.

Parameters:

namedWindowName - name of window

typeName - name to use

statementStopService - for handling stops

eventAdapterService - for event type info

Returns:

revision event type

isRevisionTypeName

boolean isRevisionTypeName(java.lang.String name)

Upon named window creation, check if the name used is a revision event type name.

Parameters:

name - to check

Returns:

true if revision event type, false if not

getValueAddProcessor

ValueAddEventProcessor getValueAddProcessor(java.lang.String name)

Gets a value-added event processor.

Parameters:

name - of the value-add events

Returns:

processor

getValueAddedTypes

EventType[] getValueAddedTypes()

Returns all event types representing value-add event types.

Returns:

value-add event type