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 Object
implements DataFlowSourceOperator

Field Summary

Fields

Modifier and Type	Field and Description
Object[]	instructions

Constructor Summary

Constructors

Constructor and Description
DefaultSupportSourceOp()
DefaultSupportSourceOp(Object[] instructions)

Method Summary

Modifier and Type	Method and Description
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 Object[] instructions

Constructor Detail

DefaultSupportSourceOp

public DefaultSupportSourceOp()

DefaultSupportSourceOp

public DefaultSupportSourceOp(Object[] instructions)

Method Detail

getCurrentCount

public int getCurrentCount()

next

public void next()
          throws InterruptedException

Specified by:

next in interface DataFlowSourceOperator

Throws:

InterruptedException

initialize

public DataFlowOpInitializeResult initialize(DataFlowOpInitializateContext context)
                                      throws Exception

Specified by:

initialize in interface DataFlowOpLifecycle

Throws:

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