Resultados da pesquisa a pedido "flink-streaming"
Qual é / são as principais diferenças entre Flink e Storm?
Flink foicomparado ao Spark [https://stackoverflow.com/questions/28082581/what-is-the-differences-between-apache-spark-and-apache-flink] , que, a meu ver, é a comparação incorreta porque compara um sistema de processamento de eventos em janelas ...
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 ...
Apache flink no Kubernetes - Continuar o trabalho se o jobmanager falhar
Eu quero executar um trabalho de flink no kubernetes, usando um back-end de estado (persistente) parece que os gerenciadores de tarefas não são problema, pois eles podem perguntar ao gerenciador de tarefas de que ponto de verificação eles ...
Ordenação de registros no fluxo
Aqui estão algumas das consultas que tenho: Eu tenho dois fluxos diferentesstream1 estream2 em que os elementos estão em ordem. 1) Agora quando eu façokeyBy em cada um desses fluxos, a ordem será mantida? (Como todos os grupos aqui serão ...