快速入門(mén)
更新時(shí)間:
本文介紹如何快速通過(guò)Lindorm計(jì)算引擎使用SQL語(yǔ)言進(jìn)行數(shù)據(jù)讀寫(xiě)。
前提條件
已開(kāi)通Lindorm寬表引擎。具體操作,請(qǐng)參見(jiàn)創(chuàng)建實(shí)例。
已開(kāi)通Lindorm計(jì)算引擎。具體操作,請(qǐng)參見(jiàn)開(kāi)通與變配。
已將客戶端IP地址添加至Lindorm白名單。具體操作,請(qǐng)參見(jiàn)設(shè)置白名單。
步驟一:環(huán)境準(zhǔn)備
下載Spark發(fā)布包。
解壓Spark發(fā)布包。
使用解壓后的路徑設(shè)置SPARK_HOME環(huán)境變量。
export SPARK_HOME=/path/to/spark/;
填寫(xiě)配置文件:
$SPARK_HOME/conf/beeline.conf
。endpoint:Lindorm計(jì)算引擎的JDBC地址。如何獲取,請(qǐng)參見(jiàn)查看計(jì)算引擎連接地址。
user:寬表引擎的用戶名。
password:寬表用戶名對(duì)應(yīng)的密碼。
shareResource:多個(gè)交互會(huì)話之間是否共享Spark資源,默認(rèn)值為
true
。
開(kāi)通Lindorm Hive服務(wù),開(kāi)通方法請(qǐng)參見(jiàn)開(kāi)通Hive服務(wù)。
步驟二:寫(xiě)入數(shù)據(jù)
進(jìn)入
$SPARK_HOME/bin
目錄并運(yùn)行./beeline
命令。在交互會(huì)話中輸入以下SQL語(yǔ)句。
-- 創(chuàng)建表 CREATE TABLE test (id INT, name STRING); -- 插入數(shù)據(jù) INSERT INTO test VALUES (0, 'Jay'), (1, 'Edison');
步驟三:讀取數(shù)據(jù)
運(yùn)行
/bin/beeline
命令。在交互會(huì)話中輸入以下SQL語(yǔ)句。
SELECT id, name FROM test;
文檔內(nèi)容是否對(duì)您有幫助?