Flink擴展 Table/SQL Scalar 函數的實現

overview 本文檔以TO_BASE64函數爲例,介紹如何實現、擴展Flink Table&SQL Scalar function。java 使用方式 自定義的Scalar函數有多種使用方式,咱們以測試代碼來了解一下,具體是如何使用的:git @Test def testToBase64(): Unit = { testAllApis( 'f0.toBase64(),
相關文章
相關標籤/搜索