このトピックでは、Table Store データテーブルの使用方法について説明します。
構文
CREATE TABLE tbName
USING tablestore
OPTIONS(propertyName=propertyValue[,propertyName=propertyValue]*);
設定パラメーター
パラメーター | 説明 | 必須 |
---|---|---|
access.key.id | Alibaba Cloud によって提供される AccessKey ID。 | はい |
access.key.secret | Alibaba Cloud によって提供される AccessKey Secret 。 | はい |
endpoint | Table Store API のエンドポイント。 | はい |
table.name | Table Store データテーブルの名前。 | はい |
instance.name | Table Store インスタンスの名前。 | はい |
batch.update.size | 一度に Table Store に更新されるデータの数。 このパラメーターは、データがデータベースに書き込まれるときに有効になります。 デフォルト値は 0 です。これは、データが 1 つずつ更新されることを示します。 パラメーターを小さな数に設定することは推奨しません。 | いいえ |
catalog | JSON 形式の Table Store データテーブルのフィールドの記述。 | はい |
- catalog 設定例を次に示します。
上記の例では、Table Store table1 のスキーマを記述しています。 この例では、関連情報が列 1 から 8 に定義されています。{"columns":{ "col0":{"cf":"cf0", "col":"col0", "type":"string"}, "col1":{"cf":"cf1", "col":"col1", "type":"boolean"}, "col2":{"cf":"cf2", "col":"col2", "type":"double"}, "col3":{"cf":"cf3", "col":"col3", "type":"float"}, "col4":{"cf":"cf4", "col":"col4", "type":"int"}, "col5":{"cf":"cf5", "col":"col5", "type":"bigint"}, "col6":{"cf":"cf6", "col":"col6", "type":"smallint"}, "col7":{"cf":"cf7", "col":"col7", "type":"string"}, "col8":{"cf":"cf8", "col":"col8", "type":"tinyint"} }
テーブルスキーマ
Table Store データテーブルを作成するとき、データテーブルのフィールドを明示的に定義する必要はありません。 たとえば、有効なテーブル作成文を次に示します。
spark-sql> CREATE DATABASE IF NOT EXISTS default;
spark-sql> USE default;
spark-sql> DROP TABLE IF EXISTS ots_table_test;
spark-sql> CREATE TABLE ots_table_test
> USING tablestore
> OPTIONS(
> endpoint="http://xxx.cn-hangzhou.vpc.ots.aliyuncs.com",
> access.key.id="yHiu*******BG2s",
> access.key.secret="ABctuw0M***************iKKljZy",
> table.name="test",
> instance.name="myInstance",
> batch.update.size = "100"、
> catalog='{"columns":{"pk":{"col":"pk","type":"string"},"data":{"col":"data","type":"string"}}}');
spark-sql> DESC ots_table_test;
pk string NULL
data string NULL
Time taken: 0.501 seconds, Fetched 2 row(s)