我目前正在使用 Apache flink 并在其中使用 RxJava,我的问题是:同时使用它们是否合适?因为我的 flink 操作始终是映射函数,并且在其中我大量使用 Rx,例如从 flink 中获取元组并对其进行异步操作(转到数据库,写入队列等),但我没有结束当 Rxjava 以处理结束时,使用 flink 向我公开的大多数方法和我的程序步骤返回 json。
你能告诉我这是否是 flink 的正确用法,或者是否有更好的方法来做我需要做的事情。(比如使用它,但在 flink 步骤或类似的东西之间传递 observables)。
谢谢。