本文介紹了Presto自定義UDF的處理方法,對大家解決問題具有一定的參考價值,需要的朋友們下面隨著小編來一起學習吧!
問題描述
我已經(jīng)創(chuàng)建了一個已注冊的自定義UDF,但當我嘗試選擇CUSTOM_UDF(10)時,收到以下錯誤:
Exact implementation of BasicPlatform do not match expected java types
這是我的UDF,我似乎不知道它出了什么問題:
公共類ScalarUdf{
private ScalarUdfs() {};
@ScalarFunction("basic_platform")
@SqlType(StandardTypes.VARCHAR)
public static Slice BasicPlatform(@SqlNullable @SqlType(StandardTypes.INTEGER) Integer id) {
final Slice IOS = Slices.utf8Slice("iOS");
final Slice ANDROID = Slices.utf8Slice("Android");
final Slice WEB = Slices.utf8Slice("Web");
final Slice OTHER = Slices.utf8Slice("Other");
final Map<Integer, Slice> PLATFORM_MAP = new HashMap<Integer, Slice>() {{
put(20, IOS);
put(42, ANDROID);
put(100, WEB);
}};
if (id == null || !PLATFORM_MAP.containsKey(id)) {
return OTHER;
}
return PLATFORM_MAP.get(id);
}
}
有沒有什么明顯的問題?我希望它返回一個給定int作為參數(shù)的字符串,并且我認為Java和SQL類型匹配(Integer->Integer),(Slice->varchar)。
謝謝
推薦答案
該問題也在presto-users被問答:
您必須使用@SqlNullable @SqlType(StandardTypes.INTEGER) Long id
(因為在Java中SQLinteger
由Long
支持)。
這篇關于Presto自定義UDF的文章就介紹到這了,希望我們推薦的答案對大家有所幫助,