Как реализовать foreach в flink?

Question

Мне нужно использовать foreach в flink. Есть ли кто-нибудь, кто может показать пример о том, как использовать карту() в flink для реализации foreach в искрах?

Answer 1

Использование карты() в качестве замены foreach() должно работать - вы можете просто поместить свой код foreach в map(), а затем вернуть исходный элемент в конце функции.

Если вас не интересует содержимое потока данных после «foreach», и вам понадобятся только побочные эффекты, возможно, стоит использовать или внедрить приемник. Например, если требование состоит в том, чтобы вставить данные в базу данных или систему обмена сообщениями или в файл, приемник, скорее всего, лучший выбор.