メインコンテンツまでスキップ
バージョン: Stable-3.3

Overview

このトピックでは、catalog とは何か、そして catalog を使用して内部データと外部データを管理およびクエリする方法について説明します。

StarRocks は v2.3 以降で catalog 機能をサポートしています。catalog により、内部データと外部データを一つのシステムで管理でき、さまざまな外部システムに保存されているデータを簡単にクエリおよび分析する柔軟な方法を提供します。

基本概念​

  • 内部データ: StarRocks に保存されているデータを指します。
  • 外部データ: Apache Hive™、Apache Iceberg、Apache Hudi、Delta Lake、JDBC などの外部データソースに保存されているデータを指します。

Catalog​

現在、StarRocks は internal catalog と external catalog の2種類の catalog を提供しています。

figure1

  • Internal catalog は StarRocks の内部データを管理します。たとえば、CREATE DATABASE または CREATE TABLE ステートメントを実行してデータベースまたはテーブルを作成すると、そのデータベースまたはテーブルは internal catalog に保存されます。各 StarRocks クラスターには default_catalog という名前の internal catalog が1つだけあります。

  • External catalog は外部で管理されているメタストアへのリンクのように機能し、StarRocks に外部データソースへの直接アクセスを提供します。データロードや移行を行わずに外部データを直接クエリできます。現在、StarRocks は次の種類の external catalog をサポートしています。

    • Hive catalog: Hive からデータをクエリするために使用されます。
    • Iceberg catalog: Iceberg からデータをクエリするために使用されます。
    • Hudi catalog: Hudi からデータをクエリするために使用されます。
    • Delta Lake catalog: Delta Lake からデータをクエリするために使用されます。
    • JDBC catalog: JDBC 互換のデータソースからデータをクエリするために使用されます。
    • Elasticsearch catalog: Elasticsearch からデータをクエリするために使用されます。Elasticsearch catalog は v3.1 以降でサポートされています。
    • Paimon catalog: Paimon からデータをクエリするために使用されます。Paimon catalog は v3.1 以降でサポートされています。
    • Unified catalog: Hive、Iceberg、Hudi、Delta Lake のデータソースを統合データソースとしてクエリするために使用されます。Unified catalog は v3.2 以降でサポートされています。

    StarRocks は外部データをクエリする際に、外部データソースの次の2つのコンポーネントと対話します。

    • Metastore service: 外部データソースのメタデータにアクセスするために FEs によって使用されます。FEs はメタデータに基づいてクエリ実行計画を生成します。
    • Data storage system: 外部データを保存するために使用されます。分散ファイルシステムとオブジェクトストレージシステムの両方がデータストレージシステムとして使用され、さまざまな形式のデータファイルを保存できます。FEs がクエリ実行計画をすべての BEs または CNs に配布した後、すべての BEs または CNs がターゲットの外部データを並行してスキャンし、計算を行い、クエリ結果を返します。

Access catalog​

SET CATALOG ステートメントを使用して、現在のセッションで指定された catalog に切り替えることができます。その後、その catalog を使用してデータをクエリできます。

Query data​

Query internal data​

StarRocks 内のデータをクエリするには、Default catalog を参照してください。

Query external data​

外部データソースからデータをクエリするには、Query external data を参照してください。

Cross-catalog query​

現在の catalog からクロス catalog フェデレーテッドクエリを実行するには、catalog_name.database_name または catalog_name.database_name.table_name 形式でクエリしたいデータを指定します。

  • 現在のセッションが default_catalog.olap_db の場合に hive_db の hive_table をクエリします。

    SELECT * FROM hive_catalog.hive_db.hive_table;

  • 現在のセッションが hive_catalog.hive_db の場合に default_catalog の olap_table をクエリします。

     SELECT * FROM default_catalog.olap_db.olap_table;

  • 現在のセッションが hive_catalog.hive_db の場合に hive_catalog の hive_table と default_catalog の olap_table に対してジョインクエリを実行します。

    SELECT * FROM hive_table h JOIN default_catalog.olap_db.olap_table o WHERE h.id = o.id;

  • 現在のセッションが別の catalog の場合に、hive_catalog の hive_table と default_catalog の olap_table に対してジョインクエリをジョイン句を使用して実行します。

    SELECT * FROM hive_catalog.hive_db.hive_table h JOIN default_catalog.olap_db.olap_table o WHERE h.id = o.id;