天天看點

【Flink】Flink自定義UDF以及為函數啟用别名1.概述

【Flink】Flink自定義UDF以及為函數啟用别名1.概述

Spring Boot 面試精講

1.概述

1.1 Scalar Functions 标量函數

标量函數,是指傳回一個值的函數。标量函數是實作将0,1,或者多個标量值轉化為一個新值。

實作一個标量函數需要繼承

ScalarFunction

,并且實作一個或者多個

evaluation

方法。标量函數的行為就是通過

evaluation

方法來實作的。

evaluation

方法必須定義為

public

,命名為

eval

evaluation

方法的輸入參數類型和傳回值類型決定着标量函數的輸入參數類型和傳回值類型。

evaluation

方法也可以被重載