Package com.espertech.esper.common.internal.epl.dataflow.util

Class DefaultSupportSourceOp

java.lang.Object

com.espertech.esper.common.internal.epl.dataflow.util.DefaultSupportSourceOp

All Implemented Interfaces:

DataFlowOperator, DataFlowOperatorLifecycle, DataFlowSourceOperator

public class DefaultSupportSourceOp
extends Object
implements DataFlowSourceOperator

Field Summary

Fields

Modifier and Type	Field	Description
Object[]	instructions

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	close(DataFlowOpCloseContext openContext)
int	getCurrentCount()
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 Details

instructions

public Object[] instructions

Constructor Details

DefaultSupportSourceOp

public DefaultSupportSourceOp()

DefaultSupportSourceOp

public DefaultSupportSourceOp(Object[] instructions)

Method Details

getCurrentCount

public int getCurrentCount()

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 DataFlowOperatorLifecycle

close

public void close(DataFlowOpCloseContext openContext)

Specified by:

close in interface DataFlowOperatorLifecycle