Milinda, I have seen your work adding initial streaming SQL to Samza. Good stuff.
Which types of query are you thinking of doing next? As of calcite-1.2, the streaming extensions are in Calciteās master branch. (See https://github.com/apache/incubator-calcite/blob/master/doc/STREAM.md.) We are a couple of weeks away from the next Calcite release. If you need some work done in Calcite, now would be a good time. Julian