Digamos que eu tenho uma coleção ilimitada de frases codificadas por userid e quero um valor constantemente atualizado para saber se o usuário é irritante, podemos calcular se um usuário é irritante passando todas as frases que ele já disse para a função isAnnoying () Para sempre.

Defino a janela como global com um gatilho afterElement (1), acumulandoFiredPanes (), GroupByKey e, em seguida, tenho um ParDo que emite userid, isAnnoying

Isso funciona para sempre, acumula o estado de cada usuário, etc. Exceto que, na grande maioria das vezes, uma nova frase não muda se o usuário é irritante e, na maioria das vezes, a janela é acionada e emite uma identificação do usuário, é uma tupla irritante. é uma atualização redundante e o io não é necessário. Como eu pego essas atualizações duplicadas e descarto enquanto ainda recebo uma atualização toda vez que uma frase aparece que altera o valor isAnnoying?