Thanks Rong, Yes for some reason i thought i need a table function, but scalar works! Yes the map constructor is what i started with but then figured it doesn't support conditional entries.
On Thu, Mar 21, 2019 at 6:07 PM Rong Rong <walter...@gmail.com> wrote: > Based on what I saw in the implementation, I think you meant to implement > a ScalarFunction right? since you are only trying to structure a VarArg > string into a Map. > > If my understanding was correct. I think the Map constructor[1] is > something you might be able to leverage. It doesn't resolve your > Nullability issue though. > Otherwise you can use the Scalar UDF [2] > > -- > Rong > > [1] > https://ci.apache.org/projects/flink/flink-docs-release-1.7/dev/table/functions.html#value-construction-functions > [2] > https://ci.apache.org/projects/flink/flink-docs-release-1.7/dev/table/udfs.html#scalar-functions > > > > On Thu, Mar 21, 2019 at 5:02 PM shkob1 <shahar.kobrin...@gmail.com> wrote: > >> Looking further into the RowType it seems like this field is translated >> as a >> CURSOR rather than a map.. not sure why >> >> >> >> -- >> Sent from: >> http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/ >> >
