com.espertech.esper.common.internal.epl.fafquery.querymethod

Class FAFQueryMethodIUDBase

java.lang.Object

com.espertech.esper.common.internal.epl.fafquery.querymethod.FAFQueryMethodIUDBase

All Implemented Interfaces:

FAFQueryMethod

Direct Known Subclasses:

FAFQueryMethodIUDDelete, FAFQueryMethodIUDInsertInto, FAFQueryMethodIUDUpdate

public abstract class FAFQueryMethodIUDBase
extends Object
implements FAFQueryMethod

Starts and provides the stop method for EPL statements.

Field Summary

Fields

Modifier and Type	Field and Description
protected QueryGraph	queryGraph

Constructor Summary

Constructors

Constructor and Description
FAFQueryMethodIUDBase()

Method Summary

Modifier and Type	Method and Description
protected void	dispatch()
EPPreparedQueryResult	execute(AtomicBoolean serviceStatusProvider, FAFQueryMethodAssignerSetter assignerSetter, ContextPartitionSelector[] contextPartitionSelectors, ContextManagementService contextManagementService)
protected abstract EventBean[]	execute(FireAndForgetInstance fireAndForgetProcessorInstance)
Annotation[]	getAnnotations()
EventType	getEventType() Returns the event type of the prepared statement.
void	ready()
void	setAnnotations(Annotation[] annotations)
void	setContextName(String contextName)
void	setHasTableAccess(boolean hasTableAccess)
void	setInternalEventRouteDest(InternalEventRouteDest internalEventRouteDest)
void	setProcessor(FireAndForgetProcessor processor)
void	setQueryGraph(QueryGraph queryGraph)
void	setTableAccesses(Map<Integer,ExprTableEvalStrategyFactory> tableAccesses)

Methods inherited from class java.lang.Object

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

Field Detail

queryGraph

protected QueryGraph queryGraph

Constructor Detail

FAFQueryMethodIUDBase

public FAFQueryMethodIUDBase()

Method Detail

setContextName

public void setContextName(String contextName)

setProcessor

public void setProcessor(FireAndForgetProcessor processor)

setInternalEventRouteDest

public void setInternalEventRouteDest(InternalEventRouteDest internalEventRouteDest)

setQueryGraph

public void setQueryGraph(QueryGraph queryGraph)

setAnnotations

public void setAnnotations(Annotation[] annotations)

setTableAccesses

public void setTableAccesses(Map<Integer,ExprTableEvalStrategyFactory> tableAccesses)

setHasTableAccess

public void setHasTableAccess(boolean hasTableAccess)

execute

protected abstract EventBean[] execute(FireAndForgetInstance fireAndForgetProcessorInstance)

ready

public void ready()

Specified by:

ready in interface FAFQueryMethod

execute

public EPPreparedQueryResult execute(AtomicBoolean serviceStatusProvider,
                                     FAFQueryMethodAssignerSetter assignerSetter,
                                     ContextPartitionSelector[] contextPartitionSelectors,
                                     ContextManagementService contextManagementService)

Specified by:

execute in interface FAFQueryMethod

getEventType

public EventType getEventType()

Returns the event type of the prepared statement.

Specified by:

getEventType in interface FAFQueryMethod

Returns:

event type

getAnnotations

public Annotation[] getAnnotations()

dispatch

protected void dispatch()