Resultados da pesquisa a pedido "flink-cep"
Apache Flink: Como contar o número total de eventos em um DataStream
Eu tenho dois fluxos brutos e estou ingressando nesses fluxos e, em seguida, quero contar qual é o número total de eventos que foram ingressados e quantos não foram. Estou fazendo isso usando o mapa nojoinedEventDataStream como mostrado ...
Flink CEP Sem resultados impressos
Estou tentando imprimir uma string se Hello e world forem encontrados usando a biblioteca Flink CEP. Minha fonte é Kafka e estou usando o produtor do console para inserir os dados. Essa parte está funcionando. Posso imprimir o que entro no ...