public class BeaconSource extends 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(String name,
Object value) |
public DataFlowOpInitializeResult initialize(DataFlowOpInitializateContext context) throws Exception
initialize
in interface DataFlowOpLifecycle
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