Collectors versus Flow.Subscriber

[Dave Cramer]

On 30 April 2018 at 12:06, Douglas Surber <douglas.surber at oracle.com> wrote:

> We haven’t discussed much aside from ANSI SQL. I don’t know anything about
> postgresql logical decoding. Is it a row sequence? If so then either
> RowOperation or RowProcessorOperation should do fine. If it returns a
> result that doesn’t map to an ANSI SQL result then it would require a
> vendor specific extension.
>
>
No it is not a row sequence perse. It is stream of changes in the database.

Dave Cramer


Douglas
>
> > On Apr 28, 2018, at 1:21 PM, Alexander Kjäll <alexander.kjall at gmail.com>
> wrote:
> >
> > Hi
> >
> > I have been poking around writing an implementation of ADBA for
> postgresql
> > and have a question regarding how 'endless' datastreams should be
> handled.
> >
> > To take a concrete case is the feature in postgresql that's called
> logical
> > decoding, it lets a user subscribe to the replication stream from the
> > database.
> >
> > This isn't a stream that has an end, and by that account it doesn't
> really
> > in the stream model with collectors and would maybe fit better with the
> > Flow.Subscriber model.
> >
> > Have this usecase been considered and is there a way to implement this
> that
> > I haven't seen?
> >
> > best regards
> > Alexander Kjäll
>
>