public interface DataFlowSourceOperator extends DataFlowOpLifecycle
void
next()
close, initialize, open
void next() throws InterruptedException
InterruptedException