本文介紹如何快速通過Lindorm計算引擎使用SQL語言進行資料讀寫。
前提條件
步驟一:環境準備
下載Spark發布包。
解壓Spark發布包。
使用解壓後的路徑設定SPARK_HOME環境變數。
export SPARK_HOME=/path/to/spark/;
填寫設定檔:
$SPARK_HOME/conf/beeline.conf
。endpoint:Lindorm計算引擎的JDBC地址。如何擷取,請參見查看計算引擎串連地址。
user:寬表引擎的使用者名稱。
password:寬表使用者名稱對應的密碼。
shareResource:多個互動會話之間是否共用Spark資源,預設值為
true
。
開通Lindorm Hive服務,開通方法請參見開通Hive服務。
步驟二:寫入資料
進入
$SPARK_HOME/bin
目錄並運行./beeline
命令。在互動會話中輸入以下SQL語句。
-- 建立表 CREATE TABLE test (id INT, name STRING); -- 插入資料 INSERT INTO test VALUES (0, 'Jay'), (1, 'Edison');
步驟三:讀取資料
運行
/bin/beeline
命令。在互動會話中輸入以下SQL語句。
SELECT id, name FROM test;