Resultados da pesquisa a pedido "distributed"
Contagem de palavras acumuladas do Streaming Spark
Este é um programa de streaming de faísca escrito em scala. Conta o número de palavras de um soquete a cada 1 segundo. O resultado seria a contagem de palavras, por exemplo, a contagem de palavras do tempo de 0 a 1, e a contagem de palavras do ...
Operação da janela de transmissão do Spark
A seguir, é apresentado um código simples para obter a contagem de palavras em um tamanho de janela de 30 segundos e um tamanho de slide de 10 segundos. import org.apache.spark.SparkConf import org.apache.spark.streaming._ ...
Existe um caso de uso para recebimento sem bloqueio quando tenho threads?
Sei que o recebimento sem bloqueio não é usado tanto na passagem de mensagens, mas ainda assim alguma intuição diz que é necessário. Tomemos, por exemplo, aplicativos orientados a eventos da GUI, você precisa de alguma maneira de aguardar uma ...
Microsserviços: O que são terminais inteligentes e tubos burros?
Eu li um artigo "Microsserviços [http://martinfowler.com/articles/microservices.html#SmartEndpointsAndDumbPipes] "de Martin Fowler e acha difícil entenderponto final inteligenteareiatubos burros. Por favor, explique estes termos, exemplos são ...
A trava fornecida é inválida. O bloqueio expirou ou a mensagem já foi removida da fila
Estou usando uma fila de barramento de serviço do Microsoft azure para processar cálculos e meu programa funciona bem por algumas horas, mas então começo a receber essa exceção para todas as mensagens que processo a partir de então. Não faço ...
cache de chave / valor do tipo memcached que usa RAM e disco [fechado]
Eu tenho um aplicativo da web java que faz back-end de um serviço da web de terceiros. Ligar para o serviço web cria latência, o que é importante evitar sempre que possível. Além disso, meu aplicativo só pode fazer um determinado número de ...
Emulando desconexões de rede para testar localmente o particionamento de aplicativos distribuídos
Eu tenho várias instâncias de um aplicativo distribuído em execução no host local; toda instância se comunica com outras pessoas através de certas portas, todas as instâncias juntas formam um conjunto. (Na verdade, estou falando sobre Funcionário ...
FileNotFoundException ao usar o cache distribuído do Hadoop
Desta vez, alguém deve por favor relpy Estou lutando com a execução do meu código usando cahe distribuído. Eu já tenho os arquivos em hdfs, mas quando executo este código: import java.awt.image.BufferedImage; import ...
Equipe de desenvolvimento distribuído - Ferramentas necessárias [fechado]
Eu tenho uma equipe de desenvolvedores distribuídos globalmente em diferentes fusos horários. Quais são as melhores ferramentas para alcançar a máxima produtividade em uma equipe como essa? Estou à procura de: Fonte de controleRastreamento de ...
Jmeter Distributed Testing usando código Java
Eu sou capaz de executar o Jmeter usando o Java Code, mas se eu quiser fazer o mesmo que o Distributed Testing, como adicionar os mecanismos remotos no Java Code?