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 and 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 and 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 Detail

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 Detail

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