flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Samuel Doyle <samueldo...@gmail.com>
Subject Joining on multiple row values produced by TableFunction
Date Mon, 08 May 2017 22:27:02 GMT
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 values

This doesn't work with flink 1.2. Is there a way to accomplish this?
…

-- 

Sent from my phone

Mime
View raw message