flink定时加载外部文件-问答-阿里云开发者社区-阿里云

开发者社区> 问答> 正文

flink定时加载外部文件

frankbood 2020-11-12 15:56:20 515

读取本地一个配置文件,生成广播流,用来过滤数据。 flink任务启动的时候使用-ys将文件分发到各节点。 我改如何修改这个配置文件。

java @Override public void run(SourceContext sourceContext) throws Exception {

//读取外部文件 while (isRun) { String tmp; try (BufferedReader br = new BufferedReader(new FileReader(properties.getProperty("iot.filter.conf.file")))) { tmp = br.readLine(); }

// System.out.println(tmp); if (!StringUtils.equals(value, tmp) && tmp != null) { value = tmp; sourceContext.collect(value); } Thread.sleep(3600); } }

Java 流计算
分享到
取消 提交回答
全部回答(0)
大数据
使用钉钉扫一扫加入圈子
+ 订阅

大数据计算实践乐园,近距离学习前沿技术

推荐文章
相似问题