快速入门

本文介绍如何快速通过Lindorm计算引擎使用SQL语言进行数据读写。

前提条件

  • 已开通Lindorm宽表引擎。具体操作,请参见创建实例

  • 已开通Lindorm计算引擎。具体操作,请参见开通与变配

  • 已将客户端IP地址添加至Lindorm白名单。具体操作,请参见设置白名单

步骤一:环境准备

  1. 下载Spark发布包

  2. 解压Spark发布包。

  3. 使用解压后的路径设置SPARK_HOME环境变量。

    export SPARK_HOME=/path/to/spark/;
  4. 填写配置文件:$SPARK_HOME/conf/beeline.conf

    • endpoint:Lindorm计算引擎的JDBC地址。如何获取,请参见查看计算引擎连接地址

    • user:宽表引擎的用户名。

    • password:宽表用户名对应的密码。

    • shareResource:多个交互会话之间是否共享Spark资源,默认值为true

  5. 开通Lindorm Hive服务,开通方法请参见开通Hive服务

步骤二:写入数据

  1. 进入$SPARK_HOME/bin目录并运行./beeline命令。

  2. 在交互会话中输入以下SQL语句。

    -- 创建表
    CREATE TABLE test (id INT, name STRING);
    
    -- 插入数据
    INSERT INTO test VALUES (0, 'Jay'), (1, 'Edison');

步骤三:读取数据

  1. 运行/bin/beeline命令。

  2. 在交互会话中输入以下SQL语句。

    SELECT id, name FROM test;