public class ViewableActivatorStreamReuseView extends Object implements ViewableActivator, StopCallback
Modifier | Constructor and Description |
---|---|
protected |
ViewableActivatorStreamReuseView(EPServicesContext services,
StatementContext statementContext,
StatementSpecCompiled statementSpec,
FilterStreamSpecCompiled filterStreamSpec,
boolean join,
ExprEvaluatorContextStatement evaluatorContextStmt,
boolean filterSubselectSameStream,
int streamNum,
boolean isCanIterateUnbound) |
Modifier and Type | Method and Description |
---|---|
ViewableActivationResult |
activate(AgentInstanceContext agentInstanceContext,
boolean isSubselect,
boolean isRecoveringResilient) |
FilterStreamSpecCompiled |
getFilterStreamSpec() |
void |
stop()
Stops the underlying resources.
|
protected ViewableActivatorStreamReuseView(EPServicesContext services, StatementContext statementContext, StatementSpecCompiled statementSpec, FilterStreamSpecCompiled filterStreamSpec, boolean join, ExprEvaluatorContextStatement evaluatorContextStmt, boolean filterSubselectSameStream, int streamNum, boolean isCanIterateUnbound)
public ViewableActivationResult activate(AgentInstanceContext agentInstanceContext, boolean isSubselect, boolean isRecoveringResilient)
activate
in interface ViewableActivator
public void stop()
StopCallback
stop
in interface StopCallback
public FilterStreamSpecCompiled getFilterStreamSpec()