Resultados da pesquisa a pedido "apache-storm"
Integração Storm e Spring 4
Eu tenho um aplicativo de tempestade protótipo que lê um fluxo STOMP e armazena a saída no HBase. Funciona, mas não é muito flexível e estou tentando configurá-lo de uma maneira mais consistente com o restante de nossos aplicativos, mas não tendo ...
Armazenamento em cache distribuído no storm
Como armazenar os dados temporários no Apache storm? Na topologia de tempestade, o bolt precisa acessar os dados processados anteriormente. Eg: if the bolt processes varaiable1 with result as 20 at 10:00 AM.e de novovaraiable1 é recebido como50 ...
exceção após enviar a topologia
Eu sou novo na tempestade e tentando enviar uma topologia e encontrei isso no supervisor [/imgs/DPVfN.jpg] [/imgs/sRtVn.jpg]Encontrei isso no arquivo de log dos trabalhadores [ERROR] Async loop died! ...
como incrementar rapidamente contadores em Cassandra sem staleness
Eu tenho uma pergunta sobre Cassandra. Você sabe como o Cassandra faz atualizações / incrementos de contadores? Eu quero usar um parafuso de tempestade (CassandraCounterBatchingBolt do repositório storm-contrib no github) que grava no cassandra. ...
Parando a tempestade: o caminho certo
Existe uma maneira limpa de parar a tempestade sem matá-lo com "kill XXX", onde XXX é o PID?Eu corro "storm kill topology-name" para mata...
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 ...
Como enviar a saída de dois bicos diferentes para o mesmo parafuso?
Eu tenho dois bicos de Kafka cujos valores eu quero enviar para o mesmo raio. É possível ?
Como gravar logs em um arquivo usando o Log4j e o Storm Framework?
Estou tendo um pequeno problema ao fazer logon em um arquivo usando o log4j no storm. Antes de enviar minha topologia, ou seja, no meu método principal, escrevi algumas instruções de log e configurei o criador de logs ...