将UDF功能插入Presto的步骤是什么？

我跟着this教程和杠杆this github项目，并写了一个简单的'mysum'UDF函数。将UDF功能插入Presto的步骤是什么？

@ScalarFunction("mysum") 
@Description("Returns summation of two numbers") 
@SqlType(StandardTypes.BIGINT) 
public static long sum(@SqlType(StandardTypes.BIGINT) long num1, @SqlType(StandardTypes.BIGINT) long num2) 
{ 
    return num1 + num2; 
}

我也跟着下面的步骤，以插件的UDF但普雷斯托无法导入该功能。 因为，关于编写和插入UDF的文档很少，所以不胜感激。提前致谢。

跑mvn compile和mvn package
复制.jar文件到plugins文件夹下的急板（未压缩）目录/Users/nithin/presto-server-0.166/plugin/udfs/
开始使用bin/launcher run 在普雷斯托CLI跑select mysum(10,100)协调，但会抛出错误

当我尝试在Presto CLI中运行我的UDF（'mysum'）时，下面是错误日志。 很明显，Presto无法找到UDF，因此插入不成功。如何解决这个问题？我错过了任何一步吗？

➜ Workspaces ./presto.jar --server localhost:8080 --catalog mysql --schema default --debug 
presto:default> select mysum(99,100); 
Query 20170228_183509_00002_vr5dt failed: line 1:8: Function mysum not registered 
com.facebook.presto.sql.analyzer.SemanticException: line 1:8: Function mysum not registered 
    at com.facebook.presto.sql.analyzer.ExpressionAnalyzer$Visitor.visitFunctionCall(ExpressionAnalyzer.java:824) 
    at com.facebook.presto.sql.analyzer.ExpressionAnalyzer$Visitor.visitFunctionCall(ExpressionAnalyzer.java:255) 
    at com.facebook.presto.sql.tree.FunctionCall.accept(FunctionCall.java:111) 
    at com.facebook.presto.sql.tree.StackableAstVisitor.process(StackableAstVisitor.java:26) 
    at com.facebook.presto.sql.analyzer.ExpressionAnalyzer$Visitor.process(ExpressionAnalyzer.java:274) 
    at com.facebook.presto.sql.analyzer.ExpressionAnalyzer.analyze(ExpressionAnalyzer.java:231) 
    at com.facebook.presto.sql.analyzer.ExpressionAnalyzer.analyzeExpression(ExpressionAnalyzer.java:1406) 
    at com.facebook.presto.sql.analyzer.StatementAnalyzer.analyzeExpression(StatementAnalyzer.java:1802) 
    at com.facebook.presto.sql.analyzer.StatementAnalyzer.analyzeSelect(StatementAnalyzer.java:1623) 
    at com.facebook.presto.sql.analyzer.StatementAnalyzer.visitQuerySpecification(StatementAnalyzer.java:800) 
    at com.facebook.presto.sql.analyzer.StatementAnalyzer.visitQuerySpecification(StatementAnalyzer.java:188) 
    at com.facebook.presto.sql.tree.QuerySpecification.accept(QuerySpecification.java:127) 
    at com.facebook.presto.sql.tree.AstVisitor.process(AstVisitor.java:27) 
    at com.facebook.presto.sql.analyzer.StatementAnalyzer.visitQuery(StatementAnalyzer.java:550) 
    at com.facebook.presto.sql.analyzer.StatementAnalyzer.visitQuery(StatementAnalyzer.java:188) 
    at com.facebook.presto.sql.tree.Query.accept(Query.java:94) 
    at com.facebook.presto.sql.tree.AstVisitor.process(AstVisitor.java:27) 
    at com.facebook.presto.sql.analyzer.Analyzer.analyze(Analyzer.java:68) 
    at com.facebook.presto.sql.analyzer.Analyzer.analyze(Analyzer.java:60) 
    at com.facebook.presto.execution.SqlQueryExecution.doAnalyzeQuery(SqlQueryExecution.java:290) 
    at com.facebook.presto.execution.SqlQueryExecution.analyzeQuery(SqlQueryExecution.java:276) 
    at com.facebook.presto.execution.SqlQueryExecution.start(SqlQueryExecution.java:234) 
    at com.facebook.presto.execution.QueuedExecution.lambda$start$1(QueuedExecution.java:63) 
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) 
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) 
    at java.lang.Thread.run(Thread.java:745) 
select mysum(99,100)

来源

2017-02-28 felarof99

你的连接器插件应该提供UDF类的列表。见Plugin#getFunctions

default Set<Class<?>> getFunctions() 
{ 
    return emptySet(); 
}

请覆盖的方法，揭露UDF类的类。

来源

2017-03-15 04:40:13

将UDF功能插入Presto的步骤是什么？

回答

相关问题