com.espertech.esper.core.service

Interface InternalEventRouter

All Known Implementing Classes:

InternalEventRouterImpl

public interface InternalEventRouter

Interface for a service that routes events within the engine for further processing.

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()
EventBean	preprocess(EventBean theEvent, ExprEvaluatorContext engineFilterAndDispatchTimeContext)
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)

Method Detail

getValidatePreprocessing

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

Throws:

ExprValidationException

addPreprocessing

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

removePreprocessing

void removePreprocessing(EventType eventType,
                         UpdateDesc desc)

Remove preprocessing.

Parameters:

eventType - type to remove for

desc - update statement specification

route

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

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

Parameters:

theEvent - to route

statementHandle - provides statement resources

exprEvaluatorContext - context for expression evalauation

routeDest - routing destination

addToFront - indicator whether to add to front queue

isHasPreprocessing

boolean isHasPreprocessing()

preprocess

EventBean preprocess(EventBean theEvent,
                     ExprEvaluatorContext engineFilterAndDispatchTimeContext)

setInsertIntoListener

void setInsertIntoListener(InsertIntoListener insertIntoListener)