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 ...
Inserir linhas no HBase a partir de um parafuso Storm
Gostaria de poder escrever novas entradas no HBase a partir de uma topologia distribuída (não local) do Storm. Existem alguns projetos do GitHub que fornecem Mapeadores HBase [https://github.com/ptgoetz/storm-hbase]ouparafusos pré-fabricados ...
Página do Storm LogViewer não encontrada
Sou capaz de enviar um trabalho de topologia no cluster multilocatário. O trabalho está sendo executado. No entanto, a página do visualizador de log não está disponível. Existe alguma maneira de resolver esse problema?
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 ...
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 ...
Como configurar o cluster Apache Storm de vários nós
estou seguindohttp://jayatiatblogs.blogspot.com/2011/11/storm-installation.html [http://jayatiatblogs.blogspot.com/2011/11/storm-installation.html] & ...
Como serializar uma matriz numpy preservando as dimensões da matriz?
numpy.array.tostring parece preservar informações sobre as dimensões da matriz (consulteessa questão [https://stackoverflow.com/q/30697769/1156707]), exigindo que o usuário faça uma chamada paranumpy.array.reshape. Existe uma maneira de ...
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 ...
iniciante da tempestade com a idéia intellij, o projeto maven não conseguiu encontrar a classe
Sou iniciante na ideia de tempestade e intellij, quando importo o storm-starter (apache-storm-0.9.5.zip) para a idéia intellij (14 CE OS), tudo está bem, mas quando executo o "ExclamationTopology", um o problema aparece da ...
java.lang.ClassNotFoundException: kafka.api.OffsetRequest
Estou recebendo o erro java.lang.ClassNotFoundException kafka.api.OffsetRequest ao tentar integrar o Kafka à nossa topologia Storm. Quais versões você está executando e está funcionando? Meu pom.xml <dependency> ...