
# 怎样将OBS表映射为DLI的分区表？
#### 场景概述
用户使用Flink SQL作业时，需要创建OBS分区表，用于后续进行批处理。
#### 操作步骤
该示例将car_info数据，以day字段为分区字段，parquet为编码格式，转储数据到OBS。更多内容请参考《[数据湖探索Flink SQL语法参考](https://support.huaweicloud.com/sqlref-flink-dli/dli_08_15012.html)》。
```
create sink stream car_infos (
  carId string,
  carOwner string,
  average_speed double,
  day string
  ) partitioned by (day)
  with (
    type = "filesystem",
    file.path = "obs://obs-sink/car_infos",
    encode = "parquet",
    ak = "{{myAk}}",
    sk = "{{mySk}}"
);
```
数据最终在OBS中的存储目录结构为：obs://obs-sink/car_infos/day=xx/part-x-x。
数据生成后，可通过如下SQL语句建立OBS分区表，用于后续批处理：
1. 创建OBS分区表。
   ```
   create table car_infos (
     carId string,
     carOwner string,
     average_speed double
   )
     partitioned by (day string)
     stored as parquet
     location 'obs://obs-sink/car-infos';
   ```
   
2. 从关联OBS路径中恢复分区信息。
   ```
   alter table car_infos recover partitions;
   ```
   
 
