Similar to normal Generator Flowlet, we should also allow AbstractInputFlowlet to get data in through any user-defined means. For ex, the user might want to use Twitter4j APIs or subscribe to Kafka topics - the events thus obtained should have the ability to be processed by TigonSQL before being sent to subsequent flowlets.