日本熟妇hd丰满老熟妇,中文字幕一区二区三区在线不卡 ,亚洲成片在线观看,免费女同在线一区二区

文檔

連接Kyuubi

更新時間:

本文為您介紹如何使用Beeline或JDBC連接Kyuubi。使用Beeline連接Kyuubi時,您可以使用Zookeeper連接,或者直接連接Kyuubi服務。

前提條件

  • 已創建DataLake類型的集群,并選擇了Kyuubi服務,具體操作請參見創建集群

  • 已登錄集群,具體請參見登錄集群

使用Beeline連接Kyuubi

您可以用Hive Beeline或者Kyuubi Beeline工具(EMR集群上的工具名稱為kyuubi-beeline)連接Kyuubi Server。以下示例使用Kyuubi Beeline工具連接Kyuubi。

方式一:使用Zookeeper連接Kyuubi服務(推薦)

kyuubi-beeline -n user1 \
  -u "jdbc:hive2://master-1-1:2181/;serviceDiscoveryMode=zooKeeper;zooKeeperNamespace=kyuubi"

方式二:直接連接Kyuubi服務

kyuubi-beeline -n user1 -u "jdbc:hive2://master-1-1:10009/"

提交SQL文件示例如下。

kyuubi-beeline -n user1 -u "jdbc:hive2://master-1-1:10009/" -f query1.sql

使用JDBC Driver連接Kyuubi

以下為您介紹Java應用如何使用Hive提供的JDBC Driver連接Kyuubi。代碼示例以Maven工程舉例。

Maven依賴

在Maven工程中加入如下依賴。

<dependency>
    <groupId>org.apache.hive</groupId>
    <artifactId>hive-jdbc</artifactId>
    <version>2.3.9</version>
</dependency>

代碼示例

import java.sql.*;

public class JDBCTest {
    private static String driverName = "org.apache.hive.jdbc.HiveDriver";
    private static String kyuubiJdbcUrl = "jdbc:hive2://master-1-1:10009/default;";

    public static void main(String[] args) throws Exception {
        Class.forName(driverName);
        Connection conn = DriverManager.getConnection(kyuubiJdbcUrl);
        Statement st = conn.createStatement();
        ResultSet res = st.executeQuery("show databases");
        while (res.next()) {
            System.out.println(res.getString(1));
        }
        res.close();
        st.close();
        conn.close();
    }
}

參考文檔