Hi everybody, I started to sketch the syntax of the streaming Table API.
--> https://docs.google.com/document/d/19kSOAOINKCSWLBCKRq2WvNtmuaA9o3AyCh2ePqr3V5E/edit?usp=sharing The draft is of course inspired by the current Table API but also from Calcite's StreamingSQL draft [1]. In the the version, the syntax allows to run the same query over data streams and data sets, which is a nice property, IMO. It supports different types of aggregation windows and event and processing time. A few things are still missing, most importantly joins (stream-stream, stream-table) and strategies to handle late arriving events. Please review and give feedback if you are interested. Thanks, Fabian [1] http://calcite.apache.org/docs/stream.html
