创建OSS结果表
阿里云对象存储服务OSS（Object Storage Service）为您提供基于网络的数据存取服务。使用OSS，您可以通过网络随时存储和调用包括文本、图片、音频和视频等在内的各种非结构化数据文件。
DDL定义
Flink Batch支持使用OSS文件系统作为数据存储，示例代码如下。
create table oss_input(id int,user_name VARCHAR,content VARCHAR) with (type = 'csv',path = 'oss://osspath?accessKeyId=0i70RRFJD1Oxxx&accessKeySecret=yF60EwURseo1UAxxxx&endpoint=http%3a%2f%2foss-cn-shanghai-internal.aliyuncs.com',);
WITH参数说明
| 参数 | 注释说明 | 备注 |
|---|---|---|
| path | 路径 | 必选 |
| lineDelimiter | 行分隔符 | 必选 |
| charset | 字符集 | UTF-8 |
| converter | 转换器名称 | 可选 |
| converterClass | 转换器的类 | 必选 |
本文转自实时计算——创建OSS结果表