這期內(nèi)容當中小編將會給大家?guī)碛嘘Pflinksql 中怎么自定義udf，文章內(nèi)容豐富且以專業(yè)的角度為大家分析和敘述，閱讀完這篇文章希望大家可以有所收獲。

創(chuàng)新互聯(lián)公司專注于網(wǎng)站建設，為客戶提供網(wǎng)站制作、成都網(wǎng)站制作、網(wǎng)頁設計開發(fā)服務，多年建網(wǎng)站服務經(jīng)驗，各類網(wǎng)站都可以開發(fā)，成都品牌網(wǎng)站建設，公司官網(wǎng)，公司展示網(wǎng)站，網(wǎng)站設計，建網(wǎng)站費用，建網(wǎng)站多少錢，價格優(yōu)惠，收費合理。

1、pom.xml(注意：pom中有多余的jar，本人暫時未進行剔除)

    4.0.0

    org.example
    udf
    1.0-SNAPSHOT

    
        8
        8
    

    

        
        
            org.apache.flink
            flink-table-api-java-bridge_2.11
            1.10.2
            provided
        
        
        
            org.apache.flink
            flink-table-api-scala-bridge_2.11
            1.10.2
            provided
        
        
        
            org.apache.flink
            flink-table-planner_2.11
            1.10.2
            provided
        
        
        
            org.apache.flink
            flink-table-planner-blink_2.11
            1.10.2
            provided
        
        
            org.apache.flink
            flink-streaming-scala_2.11
            1.10.2
            provided
        

        
            org.apache.flink
            flink-table-common
            1.10.2
            provided
        

    

2、java代碼：

package com.jd;

import org.apache.flink.table.functions.ScalarFunction;

public class HashCode extends ScalarFunction {
    public String eval(String s) {
        return "liuhaijing:"+s;
    }
}

3、接下來就可以參照官網(wǎng)來使用了，配上截屏

上述就是小編為大家分享的flinksql 中怎么自定義udf了，如果剛好有類似的疑惑，不妨參照上述分析進行理解。如果想知道更多相關知識，歡迎關注創(chuàng)新互聯(lián)行業(yè)資訊頻道。