Flink扩展 Table/SQL Scalar 函数的实现

overview 本文档以TO_BASE64函数为例,介绍如何实现、扩展Flink Table&SQL Scalar function。java 使用方式 自定义的Scalar函数有多种使用方式,咱们以测试代码来了解一下,具体是如何使用的:git @Test def testToBase64(): Unit = { testAllApis( 'f0.toBase64(),
相关文章
相关标签/搜索