Eu tenho dois fluxos de dados que quero combinar. O problema é que um fluxo de dados tem uma frequência muito maior que o outro e há momentos em que um fluxo não está recebendo eventos. É possível usar o último evento de um fluxo e associá-lo ao outro fluxo em todos os eventos que estão chegando?

A única solução que encontrei é usar a função de junção, mas você precisa especificar uma janela comum, onde pode aplicar a função de junção. Essa janela não é atingida quando um fluxo não está recebendo nenhum evento.

Existe a possibilidade de aplicar a função de junção em todos os eventos provenientes de um fluxo ou de outro e manter o estado do último evento consumido e usar esse evento para a função de junção?

Agradecemos antecipadamente por todas as dicas úteis!