Great, thanks for the information! Looking forward to the new release.
S.D.
On Tue, May 9, 2017 at 1:40 PM Fabian Hueske wrote:
> Flink 1.2 does not support windows in SQL.
> The upcoming Flink 1.3, which is currently in testing phase and should be
> released in a few weeks, allows you define s
Flink 1.2 does not support windows in SQL.
The upcoming Flink 1.3, which is currently in testing phase and should be
released in a few weeks, allows you define several types of windows in SQL.
There are three types of group windows [1] (note that the syntax for the
time indicators changed a bit, c
Is it possible to define windows in such a way that I can use straight sql
like with the table environment vs the sql 'like' syntax you use when using
the table api?
My project is based off Java.
Thanks
On Tue, May 9, 2017 at 10:34 AM Samuel Doyle wrote:
> I was able to get it work, albeit prob
I was able to get it work, albeit probably not the best solution, by
calling the table function twice and assigning different column aliases
On Tue, May 9, 2017, 12:43 AM Fabian Hueske wrote:
> Hi,
>
> it might be a problem, that your TableFunction is called like an attribute
> (both are called
Hi,
it might be a problem, that your TableFunction is called like an attribute
(both are called fields).
If that's not the case, can you provide more information?
- Is there an error message?
- Yes: what's the error message
- No: what's the output and what would you expect?
- Is this for batc
I want to do something like the following
.join("fields(fields) as (name, content)")
.where("text = 'password for user' && name='text' &&
!content.like('%accepted%') && name='appname' && content.like('%hostd%')")
Fields collects 4 rows in this case which contain those valu
