Extended SQL support for Streaming

[Radu Tudoran]

Hi,

 

I have created several JIRA issues with proposal implementation to support more SQL functions for streaming. As there is an ongoing discussion about supporting retraction for the Stream SQL, these features focus on the processing time. Extending them for event time would be done (in most of the cases similar) after the new retraction mechanism are merged. The JIRA issues are:

1.      

2.     FLINK-6082 - Support window definition for SQL Queries based on WHERE clause with time condition

3.     FLINK-6081 - Offset/Fetch support for SQL Streaming

4.     FLINK-6077 - Support In/Exists/Except/Any /Some/All for Stream SQL

5.     FLINK-6075 - Support Limit/Top(Sort) for Stream SQL

6.     FLINK-6073 - Support for SQL inner queries for proctime

7.      

Please let me know what you think and of course any feedback about the design/priority for the roadmap/implementation is more than welcomed.

 

Dr. Radu Tudoran

Senior Research Engineer - Big Data Expert

IT R&D Division

 

HUAWEI TECHNOLOGIES Duesseldorf GmbH

European Research Center

Riesstrasse 25, 80992 München

 

E-mail: [hidden email]

Mobile: [phone]

Telephone: [phone]

 

HUAWEI TECHNOLOGIES Duesseldorf GmbH
Hansaallee 205, 40549 Düsseldorf, Germany, www.huawei.com
Registered Office: Düsseldorf, Register Court Düsseldorf, HRB 56063,
Managing Director: Bo PENG, Wanzhou MENG, Lifang CHEN
Sitz der Gesellschaft: Düsseldorf, Amtsgericht Düsseldorf, HRB 56063,
Geschäftsführer: Bo PENG, Wanzhou MENG, Lifang CHEN

This e-mail and its attachments contain confidential information from HUAWEI, which is intended only for the person or entity whose address is listed above. Any use of the information contained herein in any way (including, but not limited to, total or partial disclosure, reproduction, or dissemination) by persons other than the intended recipient(s) is prohibited. If you receive this e-mail in error, please notify the sender by phone or email immediately and delete it!