com.espertech.esper.dataflow.util
Class DefaultSupportSourceOp

java.lang.Object
  com.espertech.esper.dataflow.util.DefaultSupportSourceOp

All Implemented Interfaces:

DataFlowOpLifecycle, DataFlowSourceOperator

public class DefaultSupportSourceOp
extends java.lang.Object
implements DataFlowSourceOperator

Field Summary

java.lang.Object[]

instructions

Constructor Summary

DefaultSupportSourceOp()

DefaultSupportSourceOp(java.lang.Object[] instructions)

Method Summary

void	close(DataFlowOpCloseContext openContext)
int	getCurrentCount()
DataFlowOpInitializeResult	initialize(DataFlowOpInitializateContext context)
void	next()
void	open(DataFlowOpOpenContext openContext)

Methods inherited from class java.lang.Object

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

Field Detail

instructions

public java.lang.Object[] instructions

Constructor Detail

DefaultSupportSourceOp

public DefaultSupportSourceOp()

DefaultSupportSourceOp

public DefaultSupportSourceOp(java.lang.Object[] instructions)

Method Detail

getCurrentCount

public int getCurrentCount()

next

public void next()
          throws java.lang.InterruptedException

Specified by:

next in interface DataFlowSourceOperator

Throws:

java.lang.InterruptedException

initialize

public DataFlowOpInitializeResult initialize(DataFlowOpInitializateContext context)
                                      throws java.lang.Exception

Specified by:

initialize in interface DataFlowOpLifecycle

Throws:

java.lang.Exception

open

public void open(DataFlowOpOpenContext openContext)

Specified by:

open in interface DataFlowOpLifecycle

close

public void close(DataFlowOpCloseContext openContext)

Specified by:

close in interface DataFlowOpLifecycle