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