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

Class FAFQueryMethodSelectExecDBBase

java.lang.Object

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

All Implemented Interfaces:

FAFQueryMethodSelectExec

Direct Known Subclasses:

FAFQueryMethodSelectExecDBPrepared, FAFQueryMethodSelectExecDBUnprepared

public abstract class FAFQueryMethodSelectExecDBBase
extends Object
implements FAFQueryMethodSelectExec

Field Summary

Fields

Modifier and Type	Field and Description
protected StatementContextRuntimeServices	services

Constructor Summary

Constructors

Constructor and Description
FAFQueryMethodSelectExecDBBase(StatementContextRuntimeServices services)

Method Summary

Modifier and Type	Method and Description
EPPreparedQueryResult	execute(FAFQueryMethodSelect select, ContextPartitionSelector[] contextPartitionSelectors, FAFQueryMethodAssignerSetter assignerSetter, ContextManagementService contextManagementService)
protected abstract Collection<EventBean>	executeInternal(ExprEvaluatorContext exprEvaluatorContext, FAFQueryMethodSelect select)
void	releaseTableLocks(FireAndForgetProcessor[] processors)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.espertech.esper.common.internal.epl.fafquery.querymethod.FAFQueryMethodSelectExec

close, prepare

Field Detail

services

protected final StatementContextRuntimeServices services

Constructor Detail

FAFQueryMethodSelectExecDBBase

public FAFQueryMethodSelectExecDBBase(StatementContextRuntimeServices services)

Method Detail

executeInternal

protected abstract Collection<EventBean> executeInternal(ExprEvaluatorContext exprEvaluatorContext,
                                                         FAFQueryMethodSelect select)

execute

public final EPPreparedQueryResult execute(FAFQueryMethodSelect select,
                                           ContextPartitionSelector[] contextPartitionSelectors,
                                           FAFQueryMethodAssignerSetter assignerSetter,
                                           ContextManagementService contextManagementService)

Specified by:

execute in interface FAFQueryMethodSelectExec

releaseTableLocks

public final void releaseTableLocks(FireAndForgetProcessor[] processors)

Specified by:

releaseTableLocks in interface FAFQueryMethodSelectExec