Hey,
I'm trying to create a SQL query which, given input from a stream with
generic class T type will create a new stream which will be in the structure
of
{
origin : T
resultOfSomeSQLCalc : Array[String]
}
it seems that just by doing "SELECT *" i can convert the resulting table
back to a stream of the origin object.
Im trying to understand how do i create that envelope with the origin
object. Something along the lines of "SELECT box(*), array(..)". I'm sensing
i need a function for that, but not sure how that looks.
Thanks for the help!
Shahar
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
