Collectors versus Flow.Subscriber

[Douglas Surber]

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.

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