pyflink map函数例子-Toy模板网

这篇具有很好参考价值的文章主要介绍了pyflink map函数例子。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

[root@master pyflink]# cat k102.py
from pyflink.datastream import StreamExecutionEnvironment

# 创建 StreamExecutionEnvironment 对象
env = StreamExecutionEnvironment.get_execution_environment()

# 读取文件，创建 DataStream 对象
data_stream = env.read_text_file('/root/pyflink/test.log')

# 对每行数据添加字符串 'aaaa'
new_stream = data_stream.map(lambda x: 'aaaa->'+x)

# 输出到控制台
new_stream.print()

# 执行任务
env.execute('Add "aaaa" to each line')

[root@master pyflink]# python k102.py
4> aaaa->3333333333333333,ccccccccccccc
2> aaaa->222222233333333,hhhhhhhhhhhhh
3> aaaa->1111111111111111,aaaaaaaaaaaaaa
1> aaaa->4444444444444444,eeeeeeeeeeeee
4> aaaa->1111111111111111,ddddddddddddd
1> aaaa->111111122222222,ffffffffffffff
3> aaaa->2222222222222222,bbbbbbbbbbbbbb
[root@master pyflink]# cat test.log
1111111111111111,aaaaaaaaaaaaaa
2222222222222222,bbbbbbbbbbbbbb
3333333333333333,ccccccccccccc
1111111111111111,ddddddddddddd
4444444444444444,eeeeeeeeeeeee
111111122222222,ffffffffffffff
222222233333333,hhhhhhhhhhhhh
[root@master pyflink]# python k102.py
2> aaaa->1111111111111111,aaaaaaaaaaaaaa
2> aaaa->2222222222222222,bbbbbbbbbbbbbb
3> aaaa->3333333333333333,ccccccccccccc
3> aaaa->1111111111111111,ddddddddddddd
4> aaaa->4444444444444444,eeeeeeeeeeeee
4> aaaa->111111122222222,ffffffffffffff
1> aaaa->222222233333333,hhhhhhhhhhhhh