com.espertech.esper.dataflow.ops

Class EPStatementSource

java.lang.Object

com.espertech.esper.dataflow.ops.EPStatementSource

All Implemented Interfaces:

StatementLifecycleObserver, DataFlowOpLifecycle, DataFlowSourceOperator

public class EPStatementSource
extends Object
implements DataFlowSourceOperator, DataFlowOpLifecycle, StatementLifecycleObserver

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	EPStatementSource.EmitterCollectorUpdateListener
static class	EPStatementSource.EmitterUpdateListener
static class	EPStatementSource.LocalEmitter
static class	EPStatementSource.PortAndMessagePair

Constructor Summary

Constructors

Constructor and Description
EPStatementSource()

Method Summary

Modifier and Type	Method and Description
void	close(DataFlowOpCloseContext openContext)
DataFlowOpInitializeResult	initialize(DataFlowOpInitializateContext context)
void	next()
void	observe(StatementLifecycleEvent theEvent) Observer statement state changes.
void	open(DataFlowOpOpenContext openContext)

Methods inherited from class java.lang.Object

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

Constructor Detail

EPStatementSource

public EPStatementSource()

Method Detail

initialize

public DataFlowOpInitializeResult initialize(DataFlowOpInitializateContext context)
                                      throws Exception

Specified by:

initialize in interface DataFlowOpLifecycle

Throws:

Exception

next

public void next()
          throws InterruptedException

Specified by:

next in interface DataFlowSourceOperator

Throws:

InterruptedException

open

public void open(DataFlowOpOpenContext openContext)

Specified by:

open in interface DataFlowOpLifecycle

observe

public void observe(StatementLifecycleEvent theEvent)

Description copied from interface: StatementLifecycleObserver

Observer statement state changes.

Specified by:

observe in interface StatementLifecycleObserver

Parameters:

theEvent - indicates statement changed

close

public void close(DataFlowOpCloseContext openContext)

Specified by:

close in interface DataFlowOpLifecycle