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.

Constructor Summary

Constructors

Constructor and Description
FAFQueryMethodSelect()

Method Summary

Modifier and Type	Method and Description
EPPreparedQueryResult	execute(AtomicBoolean serviceStatusProvider, FAFQueryMethodAssignerSetter assignerSetter, ContextPartitionSelector[] contextPartitionSelectors, ContextManagementService contextManagementService)
Annotation[]	getAnnotations()
ExprEvaluator[]	getConsumerFilters()
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,ExprTableEvalStrategyFactory>	getTableAccesses()
ExprEvaluator	getWhereClause()
boolean	isHasTableAccess()
void	ready()
void	setAnnotations(Annotation[] annotations)
void	setConsumerFilters(ExprEvaluator[] consumerFilters)
void	setContextName(String contextName)
void	setDistinct(boolean distinct)
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	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

Constructor Detail

FAFQueryMethodSelect

public FAFQueryMethodSelect()

Method Detail

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)

setDistinct

public void setDistinct(boolean distinct)

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

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

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