java - Hiveserver2 Java API

Question

我已经能够连接到使用

创建的配置单元服务器 (1)

hive --service hiveserver -v -p 10001

使用以下 java:

TSocket transport = new TSocket("hive.example.com", 10001);     
transport.setTimeout(999999999);
TBinaryProtocol protocol = new TBinaryProtocol(transport);
Client client = new ThriftHive.Client(protocol); 

transport.open();        
client.execute("SHOW TABLES");     
System.out.println(client.fetchOne());
transport.close();

hiveserver2 是否存在等效项？如果存在，它是什么？我找到的最好的是 design proposal而且我还没有找到任何文件。看起来 Cloudera 已经为 python 设置了一些东西 here

或者，从 Java 运行任意 Hive 查询的最佳方式是什么？如果相关，我将在 Hortonworks Data Platform 1.2 上运行

Answer 1

服务器进程期待来自客户端的 SASL 握手(这就是为什么您可以在堆栈跟踪中看到 TSASLServerTransport)。使用 TSAslClientTransport 作为 TSocket 连接的包装器——您还需要将适当配置的 SaslClient 实例传递给构造函数。或者，您可以修改 hive-site.xml 以关闭 SASL 身份验证。

<property><name>hive.server2.authentication</name><value>NOSASL</value></property>