Re: How do I run SQL query on a dataStream that generates my custom type.

Or even easier: You can do specify the type after the map call: eventStream.map({e: Event => toRow(e)})(Types.ROW_NAMED(...)) Regards, Timo Am 2/15/18 um 9:55 AM schrieb Timo Walther: Hi, In your case you don't have to convert to row if you don't want to. The Table API will do automatic co

Re: How do I run SQL query on a dataStream that generates my custom type.

Hi, In your case you don't have to convert to row if you don't want to. The Table API will do automatic conversion once the stream of Event is converted into a table. However, this only works if Event is a POJO. If you want to specify own type information your MapFunction can implement the R

How do I run SQL query on a dataStream that generates my custom type.

I have a stream of events of a custom type. I want to know how to convert these events into Rows that can be queried. More specifically how do I attach type information to the stream of rows that is generated? I have the following code ``` val execEnv = StreamExecutionEnvironment.getExecution