本文为您介绍如何使用 Loghub 数据表。

建表语法

CREATE TABLE tbName(columnName dataType [,columnName dataType]*)
USING loghub
OPTIONS(propertyName=propertyValue[,propertyName=propertyValue]*);

配置参数说明

参数名 说明 是否必选
sls.project LogService 项目名 是
sls.store LogStore 名 是
access.key.id 阿里云 AccessKeyId 是
access.key.secret 阿里云 AccessKeySecret 是
endpoint LogService API Endpoint 是

Table Schema

创建 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)