У меня есть два потока, оба из одного источника. Два потока происходят из-за функции фильтра в единственном исходном потоке. Два потока содержат различные типы событий. Я хочу выполнить некоторые операции с обоими событиями. Можно ли запускать операции на обоих потоках параллельно. Это происходит по умолчанию во Flink или нам нужно что-то делать?
Также я хочу выполнять операции с отдельными потоками на основе конфигурации / инструкции в Json. Код для конфигурации / инструкции существует в задании Flink. Цель Json - вызвать конкретный метод / операцию для определенного типа события. Является ли это хорошим подходом при проектировании работы Flink.