Package 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, FAFQueryMethodSessionPrepared, FAFQuerySession, FAFQuerySessionUnprepared

Direct Known Subclasses:

FAFQueryMethodIUDDelete, FAFQueryMethodIUDInsertInto, FAFQueryMethodIUDUpdate

public abstract class FAFQueryMethodIUDBase
extends Object
implements FAFQueryMethod, FAFQueryMethodSessionPrepared, FAFQuerySessionUnprepared

Starts and provides the stop method for EPL statements.

Field Summary

Fields

Modifier and Type	Field	Description
protected QueryGraph	queryGraph

Fields inherited from interface com.espertech.esper.common.internal.epl.fafquery.querymethod.FAFQueryMethod

EPTYPE

Constructor Summary

Constructors

Constructor	Description
FAFQueryMethodIUDBase()

Method Summary

Modifier and Type	Method	Description
void	close()
protected void	dispatch()
protected abstract EventBean[]	execute(FireAndForgetInstance fireAndForgetProcessorInstance)
EPPreparedQueryResult	execute(AtomicBoolean serviceStatusProvider, FAFQueryMethodAssignerSetter assignerSetter, ContextPartitionSelector[] contextPartitionSelectors, ContextManagementService contextManagementService)
Annotation[]	getAnnotations()
EventType	getEventType()	Returns the event type of the prepared statement.
Map<Integer,SubSelectFactory>	getSubselects()
void	init()
FAFQueryMethodSessionPrepared	prepared()
FAFQueryMethodSessionPrepared	readyPrepared(StatementContextRuntimeServices services)
FAFQuerySessionUnprepared	readyUnprepared(StatementContextRuntimeServices services)
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	setSubselects(Map<Integer,SubSelectFactory> subselects)
void	setTableAccesses(Map<Integer,ExprTableEvalStrategyFactory> tableAccesses)
FAFQuerySessionUnprepared	unprepared()

Methods inherited from class java.lang.Object

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

Field Details

queryGraph

protected QueryGraph queryGraph

Constructor Details

FAFQueryMethodIUDBase

public FAFQueryMethodIUDBase()

Method Details

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)

getSubselects

public Map<Integer,SubSelectFactory> getSubselects()

setSubselects

public void setSubselects(Map<Integer,SubSelectFactory> subselects)

execute

protected abstract EventBean[] execute(FireAndForgetInstance fireAndForgetProcessorInstance)

readyUnprepared

public FAFQuerySessionUnprepared readyUnprepared(StatementContextRuntimeServices services)

Specified by:

readyUnprepared in interface FAFQueryMethod

readyPrepared

public FAFQueryMethodSessionPrepared readyPrepared(StatementContextRuntimeServices services)

Specified by:

readyPrepared in interface FAFQueryMethod

prepared

public FAFQueryMethodSessionPrepared prepared()

unprepared

public FAFQuerySessionUnprepared unprepared()

init

public void init()

close

public void close()

Specified by:

close in interface FAFQueryMethodSessionPrepared

execute

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

Specified by:

execute in interface FAFQuerySession

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()