日本熟妇hd丰满老熟妇,中文字幕一区二区三区在线不卡 ,亚洲成片在线观看,免费女同在线一区二区

Trino使用JindoSDK查詢OSS-HDFS服務中的數據

Trino是一個開源的分布式SQL查詢引擎,適用于交互式分析查詢。本文介紹Trino如何使用JindoSDK查詢OSS-HDFS服務中的數據。

前提條件

操作步驟

  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. 可選:如果您的環境中未包含KerberosSASL相關依賴,則需要在部署JindoSDK的所有節點安裝以下依賴。

      • UbuntuDebian

        sudo apt-get install libkrb5-dev krb5-admin-server krb5-kdc krb5-user libsasl2-dev libsasl2-modules libsasl2-modules-gssapi-mit
      • Red Hat Enterprise LinuxCentOS

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

        brew install krb5
    4. 將已下載的JindoSDK JAR包安裝到Trinoclasspath路徑下。

      cp jindosdk-x.x.x-linux/lib/*.jar  $Trino_HOME/plugin/hive-hadoop2/
  3. 配置OSS-HDFS服務實現類及AccessKey。

    1. OSS-HDFS服務實現類配置到Trino所有節點上的Hadoop配置文件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配置到Trino所有節點上的Hadoop配置文件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的其他方式

    重要

    完成以上配置后,您需要重啟Trino服務,使配置生效。

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

    以下以常用的Hive catalog為例,使用Trino創建一個OSS中的schema,并執行簡單的SQL查詢示例。由于Trino依賴Hive Metastore,因此Hive服務也需要安裝并部署JindoSDK。具體操作,請參見Hive使用JindoSDK處理OSS-HDFS服務中的數據

    1. 登錄Trino控制臺。

      trino --server <Trino_server_address>:<Trino_server_port> --catalog hive
    2. 創建OSS中的schema。

      create schema testDB with (location='oss://<Bucket>.<Endpoint>/<schema_dir>');
    3. 使用schema。

      use testDB;
    4. 創建表。

      create table tbl (key int, val int);
    5. 往表中插入數據。

      insert into tbl values (1,666);
    6. 查詢表。

      select * from tbl;