Table API, custom window

[Oleksandr Nitavskyi]

Hello guys,

 

I am curious, is there a way to define custom window (assigners/trigger/evictor) for Table/Sql Flink API? Looks like documentation keep silence about this, but is there are plans for it? Or should we go with DataStream API in case we need such kind of functionality?

 

Thanks

Oleksandr Nitavskyi

[Timo Walther]

Hi Oleksandr,

currenlty, we don't support custom windows for Table API. The Table & SQL API try to solve the most common cases but for more specific logic we recommend the DataStream API.

Regards,
Timo

Am 09.08.18 um 14:15 schrieb Oleksandr Nitavskyi:

Hello guys,

 

I am curious, is there a way to define custom window (assigners/trigger/evictor) for Table/Sql Flink API? Looks like documentation keep silence about this, but is there are plans for it? Or should we go with DataStream API in case we need such kind of functionality?

 

Thanks

Oleksandr Nitavskyi

[Fabian Hueske-2]

Hi,

regarding the plans. There are no plans to support custom window assigners and evictors.

There were some thoughts about supporting different result update strategies that could be used to return early results or update results in case of late data.

However, these features are currently not on the near or mid-term roadmap.

Most contributors are focusing on adding and improving connectors, improving the SQL client, or adding built-in functions.

There is also work for better join support.

Best, Fabian

2018-08-09 15:00 GMT+02:00 Timo Walther <[hidden email]>:

Hi Oleksandr,

currenlty, we don't support custom windows for Table API. The Table & SQL API try to solve the most common cases but for more specific logic we recommend the DataStream API.

Regards,
Timo

Am 09.08.18 um 14:15 schrieb Oleksandr Nitavskyi:

Hello guys,

 

I am curious, is there a way to define custom window (assigners/trigger/evictor) for Table/Sql Flink API? Looks like documentation keep silence about this, but is there are plans for it? Or should we go with DataStream API in case we need such kind of functionality?

 

Thanks

Oleksandr Nitavskyi