Thanks Fabian, I'm looking into a way to enrich it without having to know the internal fields of the original event type. Right now what I managed to do is to map Car into a TaggedEvent<Car> prior to the SQL query, tags being empty, then run the SQL query selecting *origin, enrich(.. ) as tags* Not sure there's a better way but i guess that works
On Thu, May 9, 2019 at 12:50 AM Fabian Hueske <fhue...@gmail.com> wrote: > Hi, > > you can use the value construction function ROW to create a nested row (or > object). > However, you have to explicitly reference all attributes that you will add. > > If you have a table Cars with (year, modelName) a query could look like > this: > > SELECT > ROW(year, modelName) AS car, > enrich(year, modelName) AS tags > FROM Cars; > > Handling many attributes is always a bit painful in SQL. > There is an effort to make the Table API easier to use for these use cases > (for example Column Operations [1]). > > Best, Fabian > > [1] https://issues.apache.org/jira/browse/FLINK-11967 > > > > Am Do., 9. Mai 2019 um 01:44 Uhr schrieb shkob1 < > shahar.kobrin...@gmail.com>: > >> Just to be more clear on my goal - >> Im trying to enrich the incoming stream with some meaningful tags based on >> conditions from the event itself. >> So the input stream could be an event looks like: >> Class Car { >> int year; >> String modelName; >> } >> >> i will have a config that are defining tags as: >> "NiceCar" -> "year > 2015 AND position("Luxury" in modelName) > 0" >> >> So ideally my output will be in the structure of >> >> Class TaggedEvent<Car> { >> Car origin; >> String[] tags; >> } >> >> >> >> >> >> >> -- >> Sent from: >> http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/ >> >
