Package com.espertech.esper.common.internal.epl.dataflow.runnables

Class GraphSourceRunnable

java.lang.Object

com.espertech.esper.common.internal.epl.dataflow.runnables.GraphSourceRunnable

All Implemented Interfaces:

BaseRunnable, DataFlowSignalListener, Runnable

public class GraphSourceRunnable
extends Object
implements BaseRunnable, DataFlowSignalListener

Constructor Summary

Constructors

Constructor	Description
GraphSourceRunnable(AgentInstanceContext agentInstanceContext, DataFlowSourceOperator graphSource, String dataFlowName, String instanceId, String operatorName, int operatorNumber, String operatorPrettyPrint, EPDataFlowExceptionHandler optionalExceptionHandler, boolean audit)

Method Summary

Modifier and Type	Method	Description
void	addCompletionListener(CompletionListener completionListener)
boolean	isShutdown()
void	next()
void	processSignal(EPDataFlowSignal signal)
void	run()
void	runSync()
void	shutdown()

Methods inherited from class java.lang.Object

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

Constructor Details

GraphSourceRunnable

public GraphSourceRunnable(AgentInstanceContext agentInstanceContext,
 DataFlowSourceOperator graphSource,
 String dataFlowName,
 String instanceId,
 String operatorName,
 int operatorNumber,
 String operatorPrettyPrint,
 EPDataFlowExceptionHandler optionalExceptionHandler,
 boolean audit)

Method Details

processSignal

public void processSignal(EPDataFlowSignal signal)

Specified by:

processSignal in interface DataFlowSignalListener

run

public void run()

Specified by:

run in interface Runnable

runSync

public void runSync()
             throws InterruptedException

Throws:

InterruptedException

addCompletionListener

public void addCompletionListener(CompletionListener completionListener)

next

public void next()
          throws InterruptedException

Throws:

InterruptedException

shutdown

public void shutdown()

Specified by:

shutdown in interface BaseRunnable

isShutdown

public boolean isShutdown()