Hi everybody, I would like to start a discussion about the targeted feature set of the Table API / SQL for Flink 1.4.0. Flink 1.3.0 was released about 2 weeks ago and we have 2.5 months (~11 weeks, until begin of September) left until the feature freeze for Flink 1.4.0.
I think it makes sense to start with a collection of desired features. Once we have a list of requested features, we might want to prioritize and maybe also assign responsibilities. When we prioritize, we should keep in mind that: - we want to have a consistent API. Larger features should be developed in a feature branch first. - the next months are typical time for vacations - we have been bottlenecked by committer resources in the last release. I think the following features would be a nice addition to the current state: - Conversion of a stream into an upsert table (with retraction, updating to the last row per key) - Joins for streaming tables - Stream-Stream (time-range predicate) there is already a PR for processing time joins - Table-Table (with retraction) - Support for late arriving records in group window aggregations - Exposing a keyed result table as queryable state Which features are others looking for? Cheers, Fabian
