操作步驟

1. 連接ECS實例。具體操作，請參見連接ECS實例。

2. 配置JindoSDK。

   1. 下載最新版本的JindoSDK JAR包。下載地址，請參見GitHub。

   2. 解壓JindoSDK JAR包。

      以下以解壓jindosdk-x.x.x-linux.tar.gz為例，如使用其他版本的JindoSDK，請替換為對應的JAR包名稱。

      tar zxvf jindosdk-x.x.x-linux.tar.gz

      說明

      x.x.x表示JindoSDK JAR包版本號。

   3. 可選：如果您的環境中未包含Kerberos和SASL相關依賴，則需要在部署JindoSDK的所有節點安裝以下依賴。

      • Ubuntu或Debian

        sudo apt-get install libkrb5-dev krb5-admin-server krb5-kdc krb5-user libsasl2-dev libsasl2-modules libsasl2-modules-gssapi-mit

      • Red Hat Enterprise Linux或CentOS

        sudo yum install krb5-server krb5-workstation cyrus-sasl-devel cyrus-sasl-gssapi cyrus-sasl-plain

      • macOS

        brew install krb5

   4. 將已下載的JindoSDK JAR包拷貝至Impala的classpath路徑下。

      cp jindosdk-x.x.x-linux/lib/*.jar  $HIVE_HOME/lib/

3. 配置OSS-HDFS服務實現類及AccessKey。

   1. 將OSS-HDFS服務實現類配置到Impala的core-site.xml文件中。

      <configuration>
          <property>
              <name>fs.AbstractFileSystem.oss.impl</name>
              <value>com.aliyun.jindodata.oss.JindoOSS</value>
          </property>
      
          <property>
              <name>fs.oss.impl</name>
              <value>com.aliyun.jindodata.oss.JindoOssFileSystem</value>
          </property>
      </configuration>

   2. 將已開啟OSS-HDFS服務的Bucket對應的AccessKey ID、AccessKey Secret預先配置在Impala的core-site.xml文件中。

      <configuration>
          <property>
              <name>fs.oss.accessKeyId</name>
              <value>LTAI********</value>
          </property>
      
          <property>
              <name>fs.oss.accessKeySecret</name>
              <value>KZo1********</value>
          </property>
      </configuration>

4. 配置OSS-HDFS服務Endpoint。

   使用OSS-HDFS服務訪問OSS Bucket時需要配置Endpoint。推薦訪問路徑格式為oss://<Bucket>.<Endpoint>/<Object>，例如oss://examplebucket.cn-shanghai.oss-dls.aliyuncs.com/exampleobject.txt。配置完成后，JindoSDK會根據訪問路徑中的Endpoint訪問對應的OSS-HDFS服務接口。

   您還可以通過其他方式配置OSS-HDFS服務Endpoint，且不同方式配置的Endpoint存在生效優先級。更多信息，請參見附錄一：配置Endpoint的其他方式。

5. 使用Impala查詢OSS-HDFS服務中的數據。

   1. 創建表。

      CREATE EXTERNAL TABLE customer_demographics (
       `cd_demo_sk` INT,
       `cd_gender` STRING,
       `cd_marital_status` STRING,
       `cd_education_status` STRING,
       `cd_purchase_estimate` INT,
       `cd_credit_rating` STRING,
       `cd_dep_count` INT,
       `cd_dep_employed_count` INT,
       `cd_dep_college_count` INT)
      STORED AS PARQUET
      LOCATION 'oss://bucket.endpoint/dir';

   2. 查詢表數據。

      select * from customer_demographics;