com.espertech.esper.core.service

Class InternalEventRouterImpl

java.lang.Object

com.espertech.esper.core.service.InternalEventRouterImpl

All Implemented Interfaces:

InternalEventRouter

public class InternalEventRouterImpl
extends Object
implements InternalEventRouter

Routing implementation that allows to pre-process events.

Constructor Summary

Constructors

Constructor and Description
InternalEventRouterImpl(String engineURI, EngineImportService engineImportService) Ctor.

Method Summary

Modifier and Type	Method and Description
void	addPreprocessing(InternalEventRouterDesc internalEventRouterDesc, InternalRoutePreprocessView outputView, StatementAgentInstanceLock agentInstanceLock, boolean hasSubselect)
InternalEventRouterDesc	getValidatePreprocessing(EventType eventType, UpdateDesc desc, Annotation[] annotations, String statementName)
boolean	isHasPreprocessing() Return true to indicate that there is pre-processing to take place.
EventBean	preprocess(EventBean theEvent, ExprEvaluatorContext exprEvaluatorContext) Pre-process the event.
void	removePreprocessing(EventType eventType, UpdateDesc desc) Remove preprocessing.
void	route(EventBean theEvent, EPStatementHandle statementHandle, InternalEventRouteDest routeDest, ExprEvaluatorContext exprEvaluatorContext, boolean addToFront) Route the event such that the event is processed as required.
void	setInsertIntoListener(InsertIntoListener insertIntoListener)

Methods inherited from class java.lang.Object

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

Constructor Detail

InternalEventRouterImpl

public InternalEventRouterImpl(String engineURI,
                               EngineImportService engineImportService)

Ctor.

Parameters:

engineURI - engine URI

engineImportService - engine imports

Method Detail

isHasPreprocessing

public boolean isHasPreprocessing()

Return true to indicate that there is pre-processing to take place.

Specified by:

isHasPreprocessing in interface InternalEventRouter

Returns:

preprocessing indicator

preprocess

public EventBean preprocess(EventBean theEvent,
                            ExprEvaluatorContext exprEvaluatorContext)

Pre-process the event.

Specified by:

preprocess in interface InternalEventRouter

Parameters:

theEvent - to preprocess

exprEvaluatorContext - expression evaluation context

Returns:

preprocessed event

setInsertIntoListener

public void setInsertIntoListener(InsertIntoListener insertIntoListener)

Specified by:

setInsertIntoListener in interface InternalEventRouter

route

public void route(EventBean theEvent,
                  EPStatementHandle statementHandle,
                  InternalEventRouteDest routeDest,
                  ExprEvaluatorContext exprEvaluatorContext,
                  boolean addToFront)

Description copied from interface: InternalEventRouter

Route the event such that the event is processed as required.

Specified by:

route in interface InternalEventRouter

Parameters:

theEvent - to route

statementHandle - provides statement resources

routeDest - routing destination

exprEvaluatorContext - context for expression evalauation

addToFront - indicator whether to add to front queue

getValidatePreprocessing

public InternalEventRouterDesc getValidatePreprocessing(EventType eventType,
                                                        UpdateDesc desc,
                                                        Annotation[] annotations,
                                                        String statementName)
                                                 throws ExprValidationException

Specified by:

getValidatePreprocessing in interface InternalEventRouter

Throws:

ExprValidationException

addPreprocessing

public void addPreprocessing(InternalEventRouterDesc internalEventRouterDesc,
                             InternalRoutePreprocessView outputView,
                             StatementAgentInstanceLock agentInstanceLock,
                             boolean hasSubselect)

Specified by:

addPreprocessing in interface InternalEventRouter

removePreprocessing

public void removePreprocessing(EventType eventType,
                                UpdateDesc desc)

Description copied from interface: InternalEventRouter

Remove preprocessing.

Specified by:

removePreprocessing in interface InternalEventRouter

Parameters:

eventType - type to remove for

desc - update statement specification