创建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 |
转换器的类 |
必选 |