阿里云对象存储服务 (OSS)
通过以下格式指定路径,OSS 对象可类似于普通文件使用:
以下代码展示了如何在 Flink 作业中使用 OSS:
为使用 oss:// scheme 的 URI 注册了默认的文件系统包装器。
配置设置
在设置好 OSS 文件系统包装器之后,需要添加一些配置以保证 Flink 有权限访问 OSS buckets。
可在 中查看配置关键字。
一些配置必须添加至 (在 Hadoop OSS 文档中定义的其它配置为用作性能调优的高级配置):
其余的凭据提供者(credential providers)可在这里中找到。