Hi,
Table API and SQL for streaming are work in progress. A first version which
supports projection, filter, and union is merged to the master branch.
Under the hood, Flink uses Calcite to optimize and translate Table API and
SQL queries.
Best, Fabian
2016-04-27 14:27 GMT+02:00 Zhangrucong :
>
Hello,
the stream table API is currently under heavy development. So far, we
support selection, filtering, and union operations. For these operations we
use the stream SQL syntax of Apache Calcite [1]. This is as simple as
adding the "STREAM" keyword.
Registering a datastream table and running a
