欢迎光临散文网 会员登陆 & 注册

Flink中Filter是怎么进行滤出操作的?

2023-06-09 14:00 作者:ingemar-  | 我要投稿

通过过滤出来一些符合条件的元素



示范


读取apache.log文件中的访问日志数据,通过过滤出来下面的访问IP是83.149.9.216的访问日志。



步骤


获取ExecutionEnvironment运行环境

使用来自Collection构建数据源

使用filter操作执行过滤

打印测试



参考代码


Flink中Filter是怎么进行滤出操作的?的评论 (共 条)

分享到微博请遵守国家法律