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 java.lang.Object
implements DataFlowSourceOperator, DataFlowOpLifecycle, StatementLifecycleObserver

Nested Class Summary

static class	EPStatementSource.EmitterCollectorUpdateListener
static class	EPStatementSource.EmitterUpdateListener
static class	EPStatementSource.LocalEmitter
static class	EPStatementSource.PortAndMessagePair

Constructor Summary

EPStatementSource()

Method Summary

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 java.lang.Exception

Specified by:

initialize in interface DataFlowOpLifecycle

Throws:

java.lang.Exception

next

public void next()
          throws java.lang.InterruptedException

Specified by:

next in interface DataFlowSourceOperator

Throws:

java.lang.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