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

Class FAFQueryMethodSelect

java.lang.Object

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

All Implemented Interfaces:

FAFQueryMethod

public class FAFQueryMethodSelect
extends Object
implements FAFQueryMethod

Starts and provides the stop method for EPL statements.

Field Summary

Fields

Modifier and Type	Field	Description
static final EPTypeClass	EPTYPE

Constructor Summary

Constructors

Constructor	Description
FAFQueryMethodSelect()

Method Summary

Modifier and Type	Method	Description
EPPreparedQueryResult	execute(AtomicBoolean serviceStatusProvider, FAFQueryMethodAssignerSetter assignerSetter, ContextPartitionSelector[] contextPartitionSelectors, ContextManagementService contextManagementService)
Annotation[]	getAnnotations()
ExprEvaluator[]	getConsumerFilters()
String	getContextModuleName()
String	getContextName()
EventPropertyValueGetter	getDistinctKeyGetter()
EventType	getEventType()	Returns the event type of the prepared statement.
JoinSetComposerPrototype	getJoinSetComposerPrototype()
FireAndForgetProcessor[]	getProcessors()
QueryGraph	getQueryGraph()
ResultSetProcessorFactoryProvider	getResultSetProcessorFactoryProvider()
FAFQueryMethodSelectExec	getSelectExec()
Map<Integer,SubSelectFactory>	getSubselects()
Map<Integer,ExprTableEvalStrategyFactory>	getTableAccesses()
ExprEvaluator	getWhereClause()
boolean	isHasTableAccess()
FAFQueryMethodSessionPrepared	readyPrepared(StatementContextRuntimeServices services)
FAFQuerySessionUnprepared	readyUnprepared(StatementContextRuntimeServices services)
void	setAnnotations(Annotation[] annotations)
void	setConsumerFilters(ExprEvaluator[] consumerFilters)
void	setContextModuleName(String contextModuleName)
void	setContextName(String contextName)
void	setDistinctKeyGetter(EventPropertyValueGetter distinctKeyGetter)
void	setHasTableAccess(boolean hasTableAccess)
void	setJoinSetComposerPrototype(JoinSetComposerPrototype joinSetComposerPrototype)
void	setProcessors(FireAndForgetProcessor[] processors)
void	setQueryGraph(QueryGraph queryGraph)
void	setResultSetProcessorFactoryProvider(ResultSetProcessorFactoryProvider resultSetProcessorFactoryProvider)
void	setSubselects(Map<Integer,SubSelectFactory> subselects)
void	setTableAccesses(Map<Integer,ExprTableEvalStrategyFactory> tableAccesses)
void	setWhereClause(ExprEvaluator whereClause)

Methods inherited from class java.lang.Object

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

Field Details

EPTYPE

public static final EPTypeClass EPTYPE

Constructor Details

FAFQueryMethodSelect

public FAFQueryMethodSelect()

Method Details

setAnnotations

public void setAnnotations(Annotation[] annotations)

setProcessors

public void setProcessors(FireAndForgetProcessor[] processors)

setResultSetProcessorFactoryProvider

public void setResultSetProcessorFactoryProvider(ResultSetProcessorFactoryProvider resultSetProcessorFactoryProvider)

setWhereClause

public void setWhereClause(ExprEvaluator whereClause)

setJoinSetComposerPrototype

public void setJoinSetComposerPrototype(JoinSetComposerPrototype joinSetComposerPrototype)

setConsumerFilters

public void setConsumerFilters(ExprEvaluator[] consumerFilters)

setQueryGraph

public void setQueryGraph(QueryGraph queryGraph)

setContextName

public void setContextName(String contextName)

setTableAccesses

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

setHasTableAccess

public void setHasTableAccess(boolean hasTableAccess)

setDistinctKeyGetter

public void setDistinctKeyGetter(EventPropertyValueGetter distinctKeyGetter)

getEventType

public EventType getEventType()

Returns the event type of the prepared statement.

Specified by:

getEventType in interface FAFQueryMethod

Returns:

event type

readyUnprepared

public FAFQuerySessionUnprepared readyUnprepared(StatementContextRuntimeServices services)

Specified by:

readyUnprepared in interface FAFQueryMethod

readyPrepared

public FAFQueryMethodSessionPrepared readyPrepared(StatementContextRuntimeServices services)

Specified by:

readyPrepared in interface FAFQueryMethod

execute

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

getAnnotations

public Annotation[] getAnnotations()

getContextName

public String getContextName()

getWhereClause

public ExprEvaluator getWhereClause()

getConsumerFilters

public ExprEvaluator[] getConsumerFilters()

getResultSetProcessorFactoryProvider

public ResultSetProcessorFactoryProvider getResultSetProcessorFactoryProvider()

getProcessors

public FireAndForgetProcessor[] getProcessors()

getJoinSetComposerPrototype

public JoinSetComposerPrototype getJoinSetComposerPrototype()

getQueryGraph

public QueryGraph getQueryGraph()

isHasTableAccess

public boolean isHasTableAccess()

getSelectExec

public FAFQueryMethodSelectExec getSelectExec()

getTableAccesses

public Map<Integer,ExprTableEvalStrategyFactory> getTableAccesses()

getDistinctKeyGetter

public EventPropertyValueGetter getDistinctKeyGetter()

getSubselects

public Map<Integer,SubSelectFactory> getSubselects()

setSubselects

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

getContextModuleName

public String getContextModuleName()

setContextModuleName

public void setContextModuleName(String contextModuleName)