That would be very cool. MongoTable could implement StreamableTable, so queries that want to read change streams could do so.
Please log a JIRA case. Julian > On Oct 2, 2018, at 5:42 PM, Andrei Sereda <[email protected]> wrote: > > 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.
