前言
在开发中很多场景下，需要通过读取外部的文件作为输入的数据源进行数据提取，分析和转换，为后续进一步的数据处理做准备，比如读取日志数据等
核心代码
使用flink读取外部数据其实很简单，只需要指定外部数据源的文件路径即可，下面直接贴出代码
import org.apache.flink.streaming.api.datastream.DataStreamSource;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
public class SoureTest2 {
public static void main(String[] args) throws Exception {
//创建执行环境
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
//从环境的集合中获取数据
String path = "E:\\code-self\\flink_study\\src\\main\\resources\\sensor.txt";
DataStreamSource<String> dataStreamSource = env.readTextFile(path);
dataStreamSource.print();
env.execute();
}
}在工程目录的resources目录下有一个sensor.txt文件，如下图所示
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。
文章由极客之音整理，本文链接：https://www.bmabk.com/index.php/post/143329.html
![[C++] 进程注入dll版](https://www.bmabk.com/wp-content/uploads/2022/05/post-loading-480x300.gif)
