public class DefaultSupportSourceOp extends java.lang.Object implements DataFlowSourceOperator
Modifier and Type | Field and Description |
---|---|
java.lang.Object[] |
instructions |
Constructor and Description |
---|
DefaultSupportSourceOp() |
DefaultSupportSourceOp(java.lang.Object[] instructions) |
Modifier and Type | Method and Description |
---|---|
void |
close(DataFlowOpCloseContext openContext) |
int |
getCurrentCount() |
DataFlowOpInitializeResult |
initialize(DataFlowOpInitializateContext context) |
void |
next() |
void |
open(DataFlowOpOpenContext openContext) |
public DefaultSupportSourceOp()
public DefaultSupportSourceOp(java.lang.Object[] instructions)
public int getCurrentCount()
public void next() throws java.lang.InterruptedException
next
in interface DataFlowSourceOperator
java.lang.InterruptedException
public DataFlowOpInitializeResult initialize(DataFlowOpInitializateContext context) throws java.lang.Exception
initialize
in interface DataFlowOpLifecycle
java.lang.Exception
public void open(DataFlowOpOpenContext openContext)
open
in interface DataFlowOpLifecycle
public void close(DataFlowOpCloseContext openContext)
close
in interface DataFlowOpLifecycle