Package com.espertech.esper.runtime.internal.dataflow.op.epstatementsource

Class EPStatementSourceOp

java.lang.Object

com.espertech.esper.runtime.internal.dataflow.op.epstatementsource.EPStatementSourceOp

All Implemented Interfaces:

com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOperator, com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOperatorLifecycle, com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowSourceOperator, DeploymentStateListener

public class EPStatementSourceOp
extends Object
implements com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowSourceOperator, com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOperatorLifecycle, DeploymentStateListener

Constructor Summary

Constructors

Constructor	Description
EPStatementSourceOp(EPStatementSourceFactory factory, com.espertech.esper.common.internal.context.util.AgentInstanceContext agentInstanceContext, String statementDeploymentId, String statementName, com.espertech.esper.common.client.dataflow.core.EPDataFlowEPStatementFilter statementFilter, com.espertech.esper.common.client.dataflow.core.EPDataFlowIRStreamCollector collector)

Method Summary

Modifier and Type	Method	Description
void	close(com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOpCloseContext openContext)
void	next()
void	onDeployment(DeploymentStateEventDeployed event)	Called when a deployment completed
void	onUndeployment(DeploymentStateEventUndeployed event)	Called when an undeployment completed
void	open(com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOpOpenContext openContext)

Methods inherited from class java.lang.Object

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

Constructor Details

EPStatementSourceOp

public EPStatementSourceOp(EPStatementSourceFactory factory,
 com.espertech.esper.common.internal.context.util.AgentInstanceContext agentInstanceContext,
 String statementDeploymentId,
 String statementName,
 com.espertech.esper.common.client.dataflow.core.EPDataFlowEPStatementFilter statementFilter,
 com.espertech.esper.common.client.dataflow.core.EPDataFlowIRStreamCollector collector)

Method Details

next

public void next()
          throws InterruptedException

Specified by:

next in interface com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowSourceOperator

Throws:

InterruptedException

open

public void open(com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOpOpenContext openContext)

Specified by:

open in interface com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOperatorLifecycle

onDeployment

public void onDeployment(DeploymentStateEventDeployed event)

Description copied from interface: DeploymentStateListener

Called when a deployment completed

Specified by:

onDeployment in interface DeploymentStateListener

Parameters:

event - deployment information

onUndeployment

public void onUndeployment(DeploymentStateEventUndeployed event)

Description copied from interface: DeploymentStateListener

Called when an undeployment completed

Specified by:

onUndeployment in interface DeploymentStateListener

Parameters:

event - undeployment information

close

public void close(com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOpCloseContext openContext)

Specified by:

close in interface com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOperatorLifecycle