Есть ли в Flink способ заставить агрегатную функцию регулярно выводить результат? ⇐ JAVA

[Anonymous]

У меня возникла проблема при написании заданий Flink: мне нужно объединить некоторые специальные операторы, но есть некоторые полные операторы, которые не требуют объединения.
Я сделал следующее, чтобы объединить тот же набор информации в функцию агрегирования. Когда в функцию вводятся два информационных объекта, выполняется объединение и вывод. К сожалению, может быть только одна информация, которая удовлетворяет условию ip,port,batch_id, а функция получает информацию и бесконечно ожидает следующей информации (на самом деле функция должна выводить эту информацию напрямую, но у меня нет возможности сообщить об этом функции).

Код: Выделить всё

Create TEMPORARY VIEW concat_view
AS select
ConcatenationFunction(info,info_type) AS complete_info
from etl_info_view
where info_type  '1' group by ip,port,batch_id;

Я рассматривал оконные функции, но две части информации, которые необходимо объединить, могут быть разделены на два разных окна, поэтому это не сработает.
Есть ли что-нибудь хорошее? идея? Спасибо миллион.

Подробнее здесь: https://stackoverflow.com/questions/785 ... esult-regu