Hi We use Postgres notifications. The spout open method registers for database notifications (add, update, delete). Each time the spout next method is called we check for pending notifications and process accordingly.
Good Luck John On Fri, Jun 27, 2014 at 12:07 AM, Sa Li <sa.in.v...@gmail.com> wrote: > Dear all > > I am doing an implementation of spout, the stream of is coming from a > postgresql ingress API (in-house project). All I know for now is to get > spout connected to postgresl, and retrieve the data periodically and store > the data to a queue and then emits to the topology. Anyone has ever done > the similar job, hope to get some instructions and details from you. > > > thanks > > Alec > > >
