flink sql 中是否可以使用 mysql 的存储过程和函数?

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

flink sql 中是否可以使用 mysql 的存储过程和函数?

macdoor
需求是这样,mysql中使用 binary(16) 存储 uuid,读取到 flink中需要转换成文本串的uuid,sql是这样

select bin_to_uuid(id, true) as text_uuid from usertable

我尝试使用,报错说  bin_to_uuid 找不到





--
Sent from: http://apache-flink.147419.n8.nabble.com/
Reply | Threaded
Open this post in threaded view
|

Re:flink sql 中是否可以使用 mysql 的存储过程和函数?

hailongwang
Hi,
  不可以的,其中链接[1] 是Flink SQL 支持的所有内置函数,链接[2] 是 Flink SQL 允许自己定义函数,来满足个性化需求。
[1] https://ci.apache.org/projects/flink/flink-docs-master/dev/table/functions/systemFunctions.html
[2] https://ci.apache.org/projects/flink/flink-docs-master/dev/table/functions/udfs.html


Best,
Hailong

在 2020-11-24 00:41:49,"macdoor" <[hidden email]> 写道:

>需求是这样,mysql中使用 binary(16) 存储 uuid,读取到 flink中需要转换成文本串的uuid,sql是这样
>
>select bin_to_uuid(id, true) as text_uuid from usertable
>
>我尝试使用,报错说  bin_to_uuid 找不到
>
>
>
>
>
>--
>Sent from: http://apache-flink.147419.n8.nabble.com/