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