com.espertech.esper.core.service
Class InternalEventRouterImpl

java.lang.Object
  com.espertech.esper.core.service.InternalEventRouterImpl

All Implemented Interfaces:

InternalEventRouter

public class InternalEventRouterImpl
extends java.lang.Object
implements InternalEventRouter

Routing implementation that allows to pre-process events.

Constructor Summary

InternalEventRouterImpl()
Ctor.

Method Summary

void	addPreprocessing(InternalEventRouterDesc internalEventRouterDesc, InternalRoutePreprocessView outputView, StatementAgentInstanceLock agentInstanceLock, boolean hasSubselect)
InternalEventRouterDesc	getValidatePreprocessing(EventType eventType, UpdateDesc desc, java.lang.annotation.Annotation[] annotations)
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()

Ctor.

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

getValidatePreprocessing

public InternalEventRouterDesc getValidatePreprocessing(EventType eventType,
                                                        UpdateDesc desc,
                                                        java.lang.annotation.Annotation[] annotations)
                                                 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