开发者社区大数据与机器学习实时计算 Flink 正文

flink 怎么样读取fastdfs上的文件，有大佬处理过吗

展开

收起

圆葱猪肉包 2023-03-27 12:27:45 357 版权

1 条回答

写回答

取消提交回答

凌云Cloud

发表文章、提出问题、分享经验、结交志同道合的朋友
可以使用 Hadoop FileSystem API 读取和写入文件。因此，可以通过配置 Hadoop FileSystem API 来读取 FastDFS 上的文件。
- 在 pom.xml 中添加以下依赖项：
- 使用 Hadoop 的 Configuration 类来配置 FileSystem
- 使用 fs.open() 方法打开 FastDFS 上的文件并读取：
代码中的地址要替换成你要读取的文件地址。
2023-03-27 13:35:10

赞同展开评论

问答分类：

流计算实时计算 Flink版

问答标签：

实时计算 Flink版文件

问答地址：

开发者社区 > 大数据与机器学习 > 实时计算 Flink > 问答

相关问答

实时计算 Flink版

Flink CDC可以给一个2.4.0cdc的Pom文件吗？

Flink CDC中sql-client的日志是应该修改哪个文件的日志级别？

140

在FlinkDepoyment的/opt/flink/conf中添加一些日志文件，我应该怎么做？

117

Flink在oss并没有生成文件是为什么？

128

在Flink CDC中，这个flink老是会产生，这个目录下的日志文件没滚动删除，咋个配置目录转移？

108

有遇到Flink CDC 读取oracle数据。导致 oracle。历史归档文件无法删除的情况吗？

在Flink CDC中这个文件怎么能够自动清理?

通过flink sql把数据写入hdfs，如何设置对生产的文件进行压缩？

393

这个是不是说明flink-cdc.yaml文件配置有问题?

flink cdc打印输出的文件太大有什么处理方法吗？

大数据与机器学习

实时计算 Flink

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。

我要提问

收录在圈子:

阿里云实时计算Flink

199212

+ 订阅

实时计算 Flink 版（Alibaba Cloud Realtime Compute for Apache Flink，Powered by Ververica）是阿里云基于 Apache Flink 构建的企业级、高性能实时大数据处理系统，由 Apache Flink 创始团队官方出品，拥有全球统一商业化品牌，完全兼容开源 Flink API，提供丰富的企业级增值功能。