本文介紹如何快速通過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;
文檔內容是否對您有幫助?