You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by Fabian Hueske <fh...@gmail.com> on 2016/02/15 16:58:23 UTC
Design Draft - Streaming Table API Syntax
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