Re: SQL aggregation functions inside the Table API

2020-11-09 Thread Ori Popowski
Thanks On Mon, Nov 9, 2020 at 4:50 PM Timo Walther wrote: > Hi Ori, > > we might support SQL expressions soon in Table API. However, we might > not support aggregate functions immediately. I would recommend to use > `sqlQuery` for now. > > The following is supported: > > val table = tenv.fromDa

Re: SQL aggregation functions inside the Table API

2020-11-09 Thread Timo Walther
Hi Ori, we might support SQL expressions soon in Table API. However, we might not support aggregate functions immediately. I would recommend to use `sqlQuery` for now. The following is supported: val table = tenv.fromDataStream(stream) val newTable = tenv.sqlQuery(s"SELECT ... FROM $table")

SQL aggregation functions inside the Table API

2020-11-09 Thread Ori Popowski
Hi, Some functions only exist in the SQL interface and are missing from the Table API. For example LAST_VALUE(expression) [1] I still want to use this function in my aggregation, and I don't want to implement a user-defined function. Can I combine an SQL expression inside my Table API? For examp