В настоящее время я использую Apache flink и использую RxJava внутри него, мои вопросы: использование обоих из них уместно? потому что мои операции flink всегда являются функциями карты, и внутри них я интенсивно использую Rx, например, беру кортежи из flink и выполняю с ними асинхронные операции (переход в БД, запись в очередь и т. д.), Но я не закончил использование большинства методов, которые открываются для меня, и шаги моей программы возвращают json, когда Rxjava завершает обработку.
Можете ли вы сказать мне, правильное ли это использование flink или есть лучший способ сделать то, что мне нужно сделать. (например, используйте его, но передавайте наблюдаемые между шагами мигания или что-то в этом роде).
Спасибо.
