flink實戰--UDF

簡介            UDF可以幫助我們極大地擴展了查詢的表達能力，flink Sql自定義函數（UDF）和spark Sql  自定義函數原理是一樣的，主要步驟無非就是，註冊函數，自定義函數類實現flink自帶的接口函數。和spark的UDF對比着來 ，下面介紹具體實現步驟。 flink的UDF分類  flink分如下三類UDF，每個類別都有自己獨特的用處 ScalarFunction：

>>阅读原文<<