火花流传输时更新基础数据

Question

Foy我的场景中，将使用火花流以实时方式从kafka读取数据a。基于来自rdbms（MySQL等）的数据A，这是累积的T + 1数据，计算将完成，result = A + a，例如。 下一个积累的数据是B，计算结果= B + a

我的问题是我如何根据来自rdbms的T + 1数据求和数据。

预先感谢您！

Answer 1

我们终于通过使用redis解决了这个问题。每天从rdbms导入数据，并在redis中更新数据，并在每天结束时将数据导出到rdbms结果表。关闭这个问题，谢谢。