com.espertech.esper.dataflow.runnables
Class GraphSourceRunnable

java.lang.Object
  com.espertech.esper.dataflow.runnables.GraphSourceRunnable

All Implemented Interfaces:

BaseRunnable, DataFlowSignalListener, java.lang.Runnable

public class GraphSourceRunnable
extends java.lang.Object
implements BaseRunnable, DataFlowSignalListener

Constructor Summary

GraphSourceRunnable(java.lang.String engineURI, java.lang.String statementName, DataFlowSourceOperator graphSource, java.lang.String dataFlowName, java.lang.String operatorName, int operatorNumber, java.lang.String operatorPrettyPrint, EPDataFlowExceptionHandler optionalExceptionHandler, boolean audit)

Method Summary

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 Detail

GraphSourceRunnable

public GraphSourceRunnable(java.lang.String engineURI,
                           java.lang.String statementName,
                           DataFlowSourceOperator graphSource,
                           java.lang.String dataFlowName,
                           java.lang.String operatorName,
                           int operatorNumber,
                           java.lang.String operatorPrettyPrint,
                           EPDataFlowExceptionHandler optionalExceptionHandler,
                           boolean audit)

Method Detail

processSignal

public void processSignal(EPDataFlowSignal signal)

Specified by:

processSignal in interface DataFlowSignalListener

run

public void run()

Specified by:

run in interface java.lang.Runnable

runSync

public void runSync()
             throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

addCompletionListener

public void addCompletionListener(CompletionListener completionListener)

next

public void next()
          throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

shutdown

public void shutdown()

Specified by:

shutdown in interface BaseRunnable

isShutdown

public boolean isShutdown()