hadoop - 来自 Hive UDF 内部的 SQL

Question

是否可以从 Hive UDF 内部对 Hive 本身执行 Sql？我试着用下面的代码片段来做:

        Class.forName("org.apache.hadoop.hive.jdbc.HiveDriver");

        Connection con = DriverManager.getConnection("jdbc:hive://localhost:10000/default", "", "");

但这给了我一个连接被拒绝的错误，而我能够从机器本身远程登录到端口。

Answer 1

Hive UDF 在任务节点上执行。除非您在每个任务节点上运行配置单元服务器(希望不是)，否则将连接 URL 指定为“localhost:10000”将不起作用。您必须给它 Hive 服务器节点的实际地址，无论是实际名称(例如 my-hive-server-node.company.com:10000)还是只是一个 ip(例如 10.20.30.40:10000)。

此外，我真的会退后一步，确保这确实是您想要做的。这似乎真的违背了 Hive 的意图。