Java API 조작 Hive
6990 단어 Hive
1.hiveserver 2 를 시작 하기 전에 자바 API 로 hive 를 조작 하기 전에 hiveserver 2 를 시작 해 야 합 니 다.(서비스 가 시작 되 지 않 았 는데 클 라 이언 트 가 어떻게 접근 할 수 있 습 니까?)
시작 명령
[root@hadoop001 bin]# hiveserver2 &
[1] 7495
[root@hadoop001 bin]# which: no hbase in (/bin:/opt/app/sqoop-1.4.6-cdh5.7.0/bin:/opt/app/hive-1.1.0-cdh5.7.0/bin:/bin:/opt/app/2.6.0-cdh5.7.0/bin:/opt/app/2.6.0-cdh5.7.0/sbin:/bin:/opt/software/findbugs-1.3.9/bin:/usr/local/protobuf/bin:/opt/software/maven-3.3.9/bin:/usr/java/jdk1.8/bin:/usr/lib64/qt-3.3/bin:/usr/local/sbin:/usr/local/bin:/sbin:/bin:/usr/sbin:/usr/bin)
클 라 이언 트 가 hive 를 조작 한 결 과 는 이 인터페이스 에서 인쇄 됩 니 다.(작업 이 성공 하면 ok 을 표시 하고 실패 하면 실패 하 는 정보 가 있 습 니 다)
2.IDEA Java API 구축
package com.ruozedata.hive;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
public class HiveJDBC {
public static String driveName="org.apache.hive.jdbc.HiveDriver";
public static String url="jdbc:hive2://192.168.187.111:10000/default";
public static String username="root";
public static String password="";
public static void main(String[] args) throws Exception {
Class.forName(driveName);
Connection con=DriverManager.getConnection(url,username,password);
Statement stms=con.createStatement();
String tableName = "testHiveDriverTable";
stms.execute("drop table if exists " + tableName);
stms.execute("create table " + tableName + " (key int, value string)");
// show tables
String sql = "show tables '" + tableName + "'";
System.out.println("Running: " + sql);
ResultSet res = stms.executeQuery(sql);
if (res.next()) {
System.out.println(res.getString(1));
}
}
}
이상 API 는 Hive 에서 testHive DriverTable 표를 만 들 었 습 니 다.표 삭제 와 같은 것 은 홈 페이지 를 참고 하 시기 바 랍 니 다.
3.검증 을 통 해 testhivedrivertable 표 가 만 들 어 졌 음 을 볼 수 있 습 니 다.
hive (default)> show tables;
OK
tab_name
emp
emp_external
testhivedrivertable
Time taken: 0.989 seconds, Fetched: 3 row(s)
server 쪽 에서 마지막 작업 결 과 를 보 여 줍 니 다(OK)
[root@hadoop001 bin]# hiveserver2 &
[1] 7495
[root@hadoop001 bin]# which: no hbase in (/bin:/opt/app/sqoop-1.4.6-cdh5.7.0/bin:/opt/app/hive-1.1.0-cdh5.7.0/bin:/bin:/opt/app/2.6.0-cdh5.7.0/bin:/opt/app/2.6.0-cdh5.7.0/sbin:/bin:/opt/software/findbugs-1.3.9/bin:/usr/local/protobuf/bin:/opt/software/maven-3.3.9/bin:/usr/java/jdk1.8/bin:/usr/lib64/qt-3.3/bin:/usr/local/sbin:/usr/local/bin:/sbin:/bin:/usr/sbin:/usr/bin)
OK
OK
OK
이 내용에 흥미가 있습니까?
현재 기사가 여러분의 문제를 해결하지 못하는 경우 AI 엔진은 머신러닝 분석(스마트 모델이 방금 만들어져 부정확한 경우가 있을 수 있음)을 통해 가장 유사한 기사를 추천합니다:
Hive 통합 ElasticSearch역할: Hive 데이터를 Es에 직접 입력 Index 를 생성합니다 Type의 매핑을 생성합니다 es-hive 관련 Jar 패키지를 다운로드하여 HDFS에 넣습니다 Hive 관련 JAR 패키지 추가 ES 외부 테이블...
텍스트를 자유롭게 공유하거나 복사할 수 있습니다.하지만 이 문서의 URL은 참조 URL로 남겨 두십시오.
CC BY-SA 2.5, CC BY-SA 3.0 및 CC BY-SA 4.0에 따라 라이센스가 부여됩니다.