HiveServer2的配置和使用 hive-site.xml配置 hiveserver2的配置 property name hive.support.concurrency / name description Enable Hive's TableLock Manager Service / description value true / value / property property name hive.zookeeper.quorum /
HiveServer2的配置和使用
hive-site.xml配置
hiveserver2的配置
property >
name > hive.support.concurrency name >
description > Enable Hive's TableLock Manager Service description >
value > true value >
property >
property >
name > hive.zookeeper.quorum name >
description >
Zookeeper quorum used by Hive's Table Lock Manager
description >
value >
value >
property >
property >
name > hive.server2.thrift.bind.host name >
value > 172.21.3.170 value >
description >
Bind host on which to run the HiveServer2 Thrift interface.Can
be overridden by setting $HIVE_SERVER2_THRIFT_BIND_HOST
description >
property >
远程访问元数据的配置
property >
name > hive.metastore.uris name >
value > thrift://172.21.1.56:9083 value >
description > Thrift uri for the remote metastore. Used by metastoreclient to connect to remote metastore. description >
property >
property >
name > hive.metastore.local name >
value > false value >
description > this is local store . description >
property >
shell交互
bin/beeline
!connectjdbc:hive2://localhost:10000 e3base e3base123 org.apache.hive.jdbc.HiveDriver (红字为当前的用户名和密码
)
Jdbc连接
远程启动元数据服务：
nohup bin/hive --servicemetastore&
启动hiveserver2服务
nohup bin/hive --servicehiveserver2 & 以后台进程的方式启动
Java客户端访问
示例代码：
package com.sitech;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import org.apache.log4j.Logger;
public class T1 {
private static Logger log = Logger. getLogger ( T1 . class );
private static String driverName = "org.apache.hive.jdbc.HiveDriver" ;
public boolean run() {
try {
Class. forName ( driverName );
Connection con = null ;
con = DriverManager. getConnection (
"jdbc:hive2://172.21.3.170:10000/hivedb" , "" , "" );
Statement stmt = con.createStatement();
ResultSet res = null ;
String sql = "selectcount(*) from test" ;
System. out .println( "Running:" + sql);
res = stmt.executeQuery(sql);
System. out .println( "ok" );
while (res.next()) {
System. out .println(res.getString(1));
}
return true ;
} catch (Exception e) {
e.printStackTrace();
log .error( "Connection:" + e.getMessage());
System. out .println( "error" );
return false ;
}
}
public static void main(String[] args) throws SQLException {
HiveJdbcClient hiveJdbcClient = new HiveJdbcClient ();
hiveJdbcClient.run();
}
}
查看更多关于HiveServer2的配置使用的详细内容...