网站首页
编程语言
数据库
系统相关
其他分享
编程问答
KeyedStream
2024-09-27
Flink(五)DataStream流处理算子
DataStream流处理算子Source算子(数据读入)Flink可以使用StreamExecutionEnvironment.addSource(source)来为我们的程序添加数据来源基于本地集合的sourceDataStream<String>words=env.fromElements("hello","flink","stream");基于文件的sourcereadTextFile(path)