本文介绍如何快速通过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;