public class StatementAgentInstanceFactorySelect extends StatementAgentInstanceFactoryBase
Modifier and Type | Field and Description |
---|---|
protected ViewableActivator[] |
eventStreamParentViewableActivators |
protected ExprEvaluator |
filterRootNodeEvaluator |
protected StreamJoinAnalysisResult |
joinAnalysisResult |
protected JoinSetComposerPrototype |
joinSetComposerPrototype |
protected int |
numStreams |
protected OutputProcessViewFactory |
outputProcessViewFactory |
protected ResultSetProcessorFactoryDesc |
resultSetProcessorFactoryDesc |
protected EPServicesContext |
services |
protected StatementContext |
statementContext |
protected StatementSpecCompiled |
statementSpec |
protected SubSelectStrategyCollection |
subSelectStrategyCollection |
protected StreamTypeService |
typeService |
protected ViewFactoryChain[] |
unmaterializedViewChain |
protected ViewResourceDelegateVerified |
viewResourceDelegate |
Constructor and Description |
---|
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) |
newContext
protected final int numStreams
protected final ViewableActivator[] eventStreamParentViewableActivators
protected final StatementContext statementContext
protected final StatementSpecCompiled statementSpec
protected final EPServicesContext services
protected final StreamTypeService typeService
protected final ViewFactoryChain[] unmaterializedViewChain
protected final ResultSetProcessorFactoryDesc resultSetProcessorFactoryDesc
protected final StreamJoinAnalysisResult joinAnalysisResult
protected final JoinSetComposerPrototype joinSetComposerPrototype
protected final SubSelectStrategyCollection subSelectStrategyCollection
protected final ViewResourceDelegateVerified viewResourceDelegate
protected final OutputProcessViewFactory outputProcessViewFactory
protected final ExprEvaluator filterRootNodeEvaluator
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)
public ViewResourceDelegateVerified getViewResourceDelegate()
public StatementAgentInstanceFactorySelectResult newContextInternal(AgentInstanceContext agentInstanceContext, boolean isRecoveringResilient)
newContextInternal
in class StatementAgentInstanceFactoryBase
protected static void addViewStopCallback(List<StopCallback> stopCallbacks, List<View> topViews)
public void assignExpressions(StatementAgentInstanceFactoryResult result)
public void unassignExpressions()
public ViewableActivator[] getEventStreamParentViewableActivators()
public ViewFactoryChain[] getUnmaterializedViewChain()
public int getNumStreams()
public StatementContext getStatementContext()
public StatementSpecCompiled getStatementSpec()
public EPServicesContext getServices()
public StreamTypeService getTypeService()
public ResultSetProcessorFactoryDesc getResultSetProcessorFactoryDesc()
public StreamJoinAnalysisResult getJoinAnalysisResult()
public JoinSetComposerPrototype getJoinSetComposerPrototype()
public SubSelectStrategyCollection getSubSelectStrategyCollection()
public OutputProcessViewFactory getOutputProcessViewFactory()