java—在ApacheFlink中,接收器可以成为下一个数据源吗

k7fdbhmy  于 2021-06-21  发布在  Flink
关注(0)|答案(1)|浏览(336)

我正在使用apache flink处理流数据。
说我有两个jar文件 a.jar 以及 b.jar . 我的问题是是否可以使用 a.jar 作为数据源 b.jar .
如果可能的话,你能给我举个简单的例子吗?
如果没有,我该怎么办?我必须使用数据库之类的东西来存储 a.jar 并以数据库作为数据源 b.jar ?

66bbxpm5

66bbxpm51#

为了获得精确的一次保证,您必须使用支持事务和流重放的流存储层来实现这种解耦。

相关问题