That would be great and an awesome example of an adapter using streaming. I haven't looked closely at Mongo's change streams, but you'd have to see if the semantics of the stream are suitable for exposing existing tables also as streams or if it would make more sense to separate streams and tables.
-- Michael Mior mm...@apache.org Le mar. 2 oct. 2018 à 20:43, Andrei Sereda <and...@sereda.cc> a écrit : > Hello, > > Since version 3.6 mongo introduced collection change streams > <https://docs.mongodb.com/v3.6/changeStreams/> which allow to observe > real-time changes of a collection. This looks very accommodating to calcite > streams <https://calcite.apache.org/docs/stream.html> which provides more > complex windowing and grouping operations. > > Do you think it makes sense to support streams in Mongo Adapter ? Would you > be interested in such feature ? > > Thanks in advance, > Andrei. >
