hadoop随笔四之eclipse连接hive

基于前面的hive表wordcount1，eclipse里读取

1. core-site.xml增加

 <property>

      <name>hadoop.proxyuser.hive.hosts</name>

       <value>*</value>

  </property>

    <property>

            <name>hadoop.proxyuser.hive.groups</name>

            <value>*</value>

    </property>

2.hive-site。xml增加

  <property>

       <name>hive.server2.thrift.port</name>

      <value>10000</value>

    </property>

    <property>

       <name>hive.server2.thrift.bind.host</name>

       <value>192.168.67.100</value>

     </property>

<property>

3.执行hive



4.java代码package myhadoop.hive;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;

public class HiveOprator {

public static void main(String[] args) throws Exception {
Class.forName("org.apache.hive.jdbc.HiveDriver");
Connection con = DriverManager.getConnection("jdbc:hive2://192.168.67.100:10000/default", "hive", "root");
Statement stmt = con.createStatement();
String querySQL = "SELECT * FROM wordcount1";

ResultSet res = stmt.executeQuery(querySQL);

while (res.next()) {
System.out.println(res.getString(1));
}

}

}


 执行结果：