com.espertech.esper.core.context.factory
Class StatementAgentInstanceFactorySelect
java.lang.Object
com.espertech.esper.core.context.factory.StatementAgentInstanceFactoryBase
com.espertech.esper.core.context.factory.StatementAgentInstanceFactorySelect
- All Implemented Interfaces:
- StatementAgentInstanceFactory
public class StatementAgentInstanceFactorySelect
- extends StatementAgentInstanceFactoryBase
Constructor Summary |
StatementAgentInstanceFactorySelect(int numStreams,
ViewableActivator[] eventStreamParentViewableActivators,
StatementContext statementContext,
StatementSpecCompiled statementSpec,
EPServicesContext services,
StreamTypeService typeService,
ViewFactoryChain[] unmaterializedViewChain,
ResultSetProcessorFactoryDesc resultSetProcessorFactoryDesc,
StreamJoinAnalysisResult joinAnalysisResult,
boolean recoveringResilient,
JoinSetComposerPrototype joinSetComposerPrototype,
SubSelectStrategyCollection subSelectStrategyCollection,
ViewResourceDelegateVerified viewResourceDelegate,
OutputProcessViewFactory outputProcessViewFactory)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
numStreams
protected final int numStreams
eventStreamParentViewableActivators
protected final ViewableActivator[] eventStreamParentViewableActivators
statementContext
protected final StatementContext statementContext
statementSpec
protected final StatementSpecCompiled statementSpec
services
protected final EPServicesContext services
typeService
protected final StreamTypeService typeService
unmaterializedViewChain
protected final ViewFactoryChain[] unmaterializedViewChain
resultSetProcessorFactoryDesc
protected final ResultSetProcessorFactoryDesc resultSetProcessorFactoryDesc
joinAnalysisResult
protected final StreamJoinAnalysisResult joinAnalysisResult
joinSetComposerPrototype
protected final JoinSetComposerPrototype joinSetComposerPrototype
subSelectStrategyCollection
protected final SubSelectStrategyCollection subSelectStrategyCollection
viewResourceDelegate
protected final ViewResourceDelegateVerified viewResourceDelegate
outputProcessViewFactory
protected final OutputProcessViewFactory outputProcessViewFactory
StatementAgentInstanceFactorySelect
public StatementAgentInstanceFactorySelect(int numStreams,
ViewableActivator[] eventStreamParentViewableActivators,
StatementContext statementContext,
StatementSpecCompiled statementSpec,
EPServicesContext services,
StreamTypeService typeService,
ViewFactoryChain[] unmaterializedViewChain,
ResultSetProcessorFactoryDesc resultSetProcessorFactoryDesc,
StreamJoinAnalysisResult joinAnalysisResult,
boolean recoveringResilient,
JoinSetComposerPrototype joinSetComposerPrototype,
SubSelectStrategyCollection subSelectStrategyCollection,
ViewResourceDelegateVerified viewResourceDelegate,
OutputProcessViewFactory outputProcessViewFactory)
getViewResourceDelegate
public ViewResourceDelegateVerified getViewResourceDelegate()
newContextInternal
public StatementAgentInstanceFactorySelectResult newContextInternal(AgentInstanceContext agentInstanceContext,
boolean isRecoveringResilient)
- Specified by:
newContextInternal
in class StatementAgentInstanceFactoryBase
addViewStopCallback
protected static void addViewStopCallback(java.util.List<StopCallback> stopCallbacks,
java.util.List<View> topViews)
assignExpressions
public void assignExpressions(StatementAgentInstanceFactoryResult result)
unassignExpressions
public void unassignExpressions()
getEventStreamParentViewableActivators
public ViewableActivator[] getEventStreamParentViewableActivators()
getUnmaterializedViewChain
public ViewFactoryChain[] getUnmaterializedViewChain()
getNumStreams
public int getNumStreams()
getStatementContext
public StatementContext getStatementContext()
getStatementSpec
public StatementSpecCompiled getStatementSpec()
getServices
public EPServicesContext getServices()
getTypeService
public StreamTypeService getTypeService()
getResultSetProcessorFactoryDesc
public ResultSetProcessorFactoryDesc getResultSetProcessorFactoryDesc()
getJoinAnalysisResult
public StreamJoinAnalysisResult getJoinAnalysisResult()
getJoinSetComposerPrototype
public JoinSetComposerPrototype getJoinSetComposerPrototype()
getSubSelectStrategyCollection
public SubSelectStrategyCollection getSubSelectStrategyCollection()
getOutputProcessViewFactory
public OutputProcessViewFactory getOutputProcessViewFactory()