在Apache Flink中手动更新状态的最佳方法是什么?-问答-阿里云开发者社区-阿里云

开发者社区> 问答> 正文
阿里云
为了无法计算的价值
打开APP
阿里云APP内打开

在Apache Flink中手动更新状态的最佳方法是什么?

2018-12-13 14:19:42 1494 1

我在股票市场项目中使用Apache Flink来计算当前的价格变化。公式是

price_change = (current_price - previous_close_price) / previous_close_price
previous_close_price是交易所前一天的证券收盘价。在市场开放前的每一天,我都需要更新previous_close_price。

现在我想出了几个解决方案,但我不知道哪个是最好的。

存储previous_close_price在redis中并在每次计算中获取价格。更新价格既简单又灵活,但此解决方案可能会降低性能。

将状态的TTL设置为1天。旧状态到期时获取新状态。但它不灵活,因为TTL是硬编码的。

广播状态模式。我不确定这个解决方案是否有效。

发送特殊消息给flink。当flink收到消息时,它会更新previous_close_price。

取消 提交回答
全部回答(1)
  • flink小助手
    2019-07-17 23:20:37

    建议在#4上使用一个变体:

    有两个来源,一个仅用于收盘价,另一个用于交易流。通过安全性键入两个流,并将它们与CoProcessFunction连接。将previous_close_price存储在CoProcessFunction中的键控状态。

    每天,在市场开放之前,以最新的收盘价流动。

    这可以使用RichCoFlatMap完成,但我建议使用CoProcessFunction,因为您可能希望使用侧输出来报告错误(例如缺少previous_close_price的证券)。

    至于其他方法:

    我认为将previous_close_price数据保存在外部数据存储中没有任何好处。
    我觉得这不太好用。没有可用于触发新数据加载的钩子,而且只有在访问状态时才会清除状态。
    这对广播状态来说不是一个好的用例,除非集群中的每个人都需要知道所有证券的收盘价。

    0 0
相关问答

1

回答

Apache Flinkd中启动一个Flink集群向客户端提交作业执行的过程是什么呢?

2021-12-08 20:28:29 381浏览量 回答数 1

1

回答

Apache Flink中的客户端怎么删除保存点呢?

2021-12-08 20:19:48 140浏览量 回答数 1

1

回答

Apache Flink中的客户端怎么设置保存点呢?

2021-12-08 20:18:41 115浏览量 回答数 1

1

回答

Apache Flink中的客户端怎么取消运行应用程序呢?

2021-12-08 20:20:05 154浏览量 回答数 1

1

回答

Apache Flink 1.13 中默认行为发生哪些变化?

2021-11-18 17:34:31 254浏览量 回答数 1

1

回答

Apache Flink:自定义触发器意外行为

2018-12-14 14:04:29 4136浏览量 回答数 1

1

回答

在Apache Flink中手动更新状态的最佳方法是什么?

2018-12-05 15:20:53 1379浏览量 回答数 1

1

回答

哪里可以在我使用Apache Flink仪表板提交的Apache Flink服务器上找到我的jar

2018-12-11 16:31:46 1961浏览量 回答数 1

1

回答

Apache Flink:如何使用SourceFunction以指定的时间间隔执行任务?

2018-11-28 16:33:00 7929浏览量 回答数 1

1

回答

Apache Flink:如何处理三个流

2018-11-28 15:58:00 2750浏览量 回答数 1
+关注
flink小助手
flink小助手会定期更新直播回顾等资料和文章干货,还整合了大家在钉群提出的有关flink的问题及回答。
文章
问答
问答排行榜
最热
最新
相关电子书
更多
《Apache Flink-重新定义计算》PDF下载
立即下载
《Apache RocketMQ 源码解析》
立即下载
《基于 Flink 的全新 Pulsar Connector 的设计、开发和使用》
立即下载