Package 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	Description
protected final StatementContextRuntimeServices	services

Constructor Summary

Constructors

Constructor	Description
FAFQueryMethodSelectExecDBBase(StatementContextRuntimeServices services)

Method Summary

Modifier and Type	Method	Description
final EPPreparedQueryResult	execute(FAFQueryMethodSelect select, ContextPartitionSelector[] contextPartitionSelectors, FAFQueryMethodAssignerSetter assignerSetter, ContextManagementService contextManagementService)
protected abstract Collection<EventBean>	executeInternal(ExprEvaluatorContext exprEvaluatorContext, FAFQueryMethodSelect select)
final 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 Details

services

protected final StatementContextRuntimeServices services

Constructor Details

FAFQueryMethodSelectExecDBBase

public FAFQueryMethodSelectExecDBBase(StatementContextRuntimeServices services)

Method Details

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