CREATE REMOTE TABLE コマンド¶

コマンド CREATE REMOTE TABLE の構文は以下のとおりです。

構文

CREATE [ OR REPLACE ] REMOTE TABLE <remote_table_name:identifier>
     INTO <data_source_name:identifier>
     [ CATALOG = <data_source_catalog:literal> ]
     [ SCHEMA = <data_source_schema:literal> ]
     [ <create index clause> ]*
     [ OPTIONS ( <option information> [ , <option information> ]* ) ]
     AS <select query>

<create index clause> ::=

    CREATE INDEX <index_name:identifier> [ UNIQUE ]

    ON ( <table index field> [, <table index field> ]* )

<table index field> :: = <index_field_name:identifier> [ ASC | DESC ]

<option information> ::=
      'batch_insert_size' = <literal>
    | 'location' = <literal>
    | 'parquet_row_group_size' = <literal>

<literal> ::= '.*' (a single quote in a literal has to be escaped with another single quote. E.g. 'literal''with a quote')

<select query> ::= (「 SELECT ステートメントの構文 」を参照)

• OR REPLACE: 指定している場合、テーブル remote_table_name がデータベースにすでに存在すれば、Virtual DataPort によってそのテーブルが削除され、再作成されます。この句を指定していない場合にこのテーブルが存在すると、このコマンドは失敗します。

• query: 他のクエリと同様に、Virtual DataPort によって実行されるクエリです。

• data_source_name: JDBC データソース。このデータソースのデータベースに新しいテーブルが作成されます。

• data_source_catalog (オプション): テーブルの作成先とする、基盤となるデータベースのカタログの名前。指定しない場合、テーブルはソースのデフォルトのカタログに作成されます。

• data_source_schema (オプション): テーブルの作成先とする、基盤となるデータベースのスキーマの名前。指定しない場合、テーブルはソースのデフォルトのスキーマに作成されます。

• index_name: 作成されるインデックスの名前。

• index_field_name: インデックスで使用するフィールドの名前。

• OPTIONS: 挿入を設定するためのオプションのパラメータ。データソースの中には一部のパラメータをサポートしていないものがあります。使用できる挿入オプションは以下のとおりです。

  • batch_insert_size: 各バッチ挿入のタプルの数。

  • location: Virtual DataPort がデータをアップロードする場所。場所はデータソースに応じて変わります。

    • Hadoop データソース (Hive、Impala、Presto、Spark): HDFS URI。

    • Redshift: S3 バケット名

    • Athena: S3 の場所

  • parquet_row_group_size: 行グループのサイズ (MB 単位)。プロパティは、Virtual DataPort が Parquet ファイルを使用してデータを挿入するデータソース (Athena、Hive、Impala、Presto、Spark) のみで有効です。

SET 'com.denodo.vdb.util.tablemanagement.sql.insertion.HdfsInsertWorker.parquet.rowGroupSize' = '<value>';

注意

データベースが HDFS (Hadoop、Impala、Presto など) に基づいている場合、このコマンドを実行する前に、データソースで一括データロードを有効にする必要があります。

このコマンドは、アダプターがキャッシュエンジンでサポートされている JDBC データソースに対してのみ機能します (キャッシュエンジンでサポートされているデータベースのリスト)。

このコマンドで作成したテーブルは、別のアプリケーションから削除する必要があります。ただし、 プロシージャ CREATE_REMOTE_TABLE で作成したテーブルは、 プロシージャ DROP_REMOTE_TABLE を使用して Denodo から削除できます。

フィールド名のいずれかがデータソースの予約語である場合、そのフィールド名は VDP によって 'field_0' に変更されます。予約語が名前になっているフィールドがほかにもある場合は、'field_1'、'field_2' のように名前が順次変更されます。

Presto では、 Hive コネクター <https://prestodb.io/docs/current/connector/hive.html> を使用している場合にのみ、 CREATE REMOTE TABLE コマンドを実行できます。

CREATE REMOTE TABLE によって、Hive および Impala では INTERNAL TABLES が作成され、Presto、Spark、Databricks では EXTERNAL TABLES が作成されます。

Presto で CREATE REMOTE TABLE コマンドによって作成したテーブルで IDU クエリを実行する場合は、Presto サーバーの構成で hive.non-managed-table-writes-enabled=true プロパティを有効にする必要があります。

Presto サーバーでこのプロパティを有効にするには、以下の手順に従います。

1. ファイル /opt/presto-server-<version>/etc/catalog/hive.properties を編集します。

2. 行 hive.non-managed-table-writes-enabled=true を追加します。

3. Presto サーバーを再起動します。

必要な権限

このコマンドを実行するには、以下の権限が必要です。

• JDBC データソースのデータベースに対する Connect 権限。

• リモートテーブルの作成先とする JDBC データソースに対する Execute 権限。

• クエリで使用するビューに対する Execute 権限。

JDBC データソースのユーザーアカウントは、基盤となるデータベースにテーブルを作成できる必要があります。

例

CREATE REMOTE TABLE reporting_customer360_state_ca
INTO common_sources.ds_jdbc_oracle
SCHEMA = 'REPORTING'
AS
SELECT * FROM customer360.customer WHERE state = 'CA';

このコマンドは以下の手順を実行します。

1. JDBC データソース ds_jdbc_oracle の基盤となるデータベースに、テーブル reporting_customer360_state_ca を作成します。

2. VDP サーバーで以下のクエリを実行します。

   SELECT *
   FROM customer360.customer
   WHERE state = 'CA';
   

3. 前のクエリの結果をテーブル reporting_customer360_state_ca に挿入します。