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

Modifier and Type	Method and Description
void	addRevisionEventType(String name, ConfigurationRevisionEventType config, EventAdapterService eventAdapterService) Adds a new revision event types.
void	addVariantStream(String variantEventTypeName, ConfigurationVariantStream variantStreamConfig, EventAdapterService eventAdapterService, EventTypeIdGenerator eventTypeIdGenerator) Adds a new variant stream.
EventType	createRevisionType(String namedWindowName, 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(String name) Gets a value-added event processor.
EventType	getValueAddUnderlyingType(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(Map<String,ConfigurationRevisionEventType> revisionTypes, Map<String,ConfigurationVariantStream> variantStreams, EventAdapterService eventAdapterService, EventTypeIdGenerator eventTypeIdGenerator) Called at initialization time, verifies configurations provided.
boolean	isRevisionTypeName(String name) Upon named window creation, check if the name used is a revision event type name.

Method Detail

init

void init(Map<String,ConfigurationRevisionEventType> revisionTypes,
          Map<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

eventTypeIdGenerator - event type id provider

addRevisionEventType

void addRevisionEventType(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(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

eventTypeIdGenerator - event type id provider

Throws:

ConfigurationException - if the configuration is invalid

getValueAddUnderlyingType

EventType getValueAddUnderlyingType(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(String namedWindowName,
                             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

eventTypeIdGenerator - event type id provider

Returns:

revision event type

isRevisionTypeName

boolean isRevisionTypeName(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(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