このトピックでは、LogHub データテーブルの使用方法について説明します。
構文
CREATE TABLE tbName(columnName dataType [,columnName dataType]*)
USING loghub
OPTIONS(propertyName=propertyValue[,propertyName=propertyValue]*);
設定パラメーター
パラメーター | 説明 | 必須 |
---|---|---|
sls.project | Log Service プロジェクトの名前。 | はい |
sls.store | Logstore の名前。 | はい |
access.key.id | Alibaba Cloud によって提供される AccessKey ID。 | はい |
access.key.secret | Alibaba Cloud によって提供される AccessKey Secret 。 | はい |
endpoint | Log Service API のエンドポイント。 | はい |
テーブルスキーマ
LogHub データテーブルを作成するとき、
データテーブルのフィールドを明示的に定義する必要があります。
たとえば、有効なテーブル作成文は次のとおりです。
spark-sql> CREATE TABLE loghub_table_test
> USING loghub
> OPTIONS
> (...)
これ以外の場合、次のエラーが返されます。
java.lang.IllegalArgumentException: requirement failed: Unable to infer the schema. The schema
specification is required to create the table. ;
有効なテーブル作成文は次のとおりです。
spark-sql> CREATE TABLE loghub_table_test(content string)
> USING loghub
> OPTIONS
> (...)
spark-sql> DESC loghub_table_test;
content string NULL
Time taken: 0.436 seconds, Fetched 1 row(s)