resultTypeTerm) $functionReference.eval(
> | ${parameters.map(_.resultTerm).mkString(", ")});
> |""".stripMargin
>
> Best, JingsongLee
>
> --
> From:Timo Walther
> Send Time:2019年5月20日(星期一) 23:03
> To:user
> Subject:Re
map(_.resultTerm).mkString(", ")});
|""".stripMargin
Best, JingsongLee
--------------
From:Timo Walther
Send Time:2019年5月20日(星期一) 23:03
To:user
Subject:Re: Generic return type on a user-defined scalar function
Hi Morrisa,
usually, this means that you class is not recognized
Hi Morrisa,
usually, this means that you class is not recognized as a POJO. Please
check again the requirements of a POJO: Default constructor, getters and
setters for every field etc. You can use
org.apache.flink.api.common.typeinfo.Types.POJO(...) to verify if your
class is a POJO or not.
Hi Flink folks,
In a Flink job using the SQL API that I’m working on, I have a custom POJO
data type with a generic field, and I would like to be able to call a
user-defined function on this field. I included a similar function below
with the business logic stubbed out, but this example has the
