public class BeaconSource extends java.lang.Object implements DataFlowSourceOperator
Constructor and Description |
---|
BeaconSource() |
Modifier and Type | Method and Description |
---|---|
void |
close(DataFlowOpCloseContext openContext) |
DataFlowOpInitializeResult |
initialize(DataFlowOpInitializateContext context) |
void |
next() |
void |
open(DataFlowOpOpenContext openContext) |
void |
setProperty(java.lang.String name,
java.lang.Object value) |
public void setProperty(java.lang.String name, java.lang.Object value)
public DataFlowOpInitializeResult initialize(DataFlowOpInitializateContext context) throws java.lang.Exception
initialize
in interface DataFlowOpLifecycle
java.lang.Exception
public void next()
next
in interface DataFlowSourceOperator
public void open(DataFlowOpOpenContext openContext)
open
in interface DataFlowOpLifecycle
public void close(DataFlowOpCloseContext openContext)
close
in interface DataFlowOpLifecycle