apache-storm

5calore

3risposta

Sto progettando un prototipo di monitor in tempo reale per l'elaborazione di quantità piuttosto elevate (> 30G/giorno) di dati numerici in streaming. Mi piacerebbe scriverlo in Clojure, poiché il ling

13calore

2risposta

UI tempesta: Differenza tra latenze di esecuzione e di processo

Ho cercato di documentare il significato di tutte le metriche di tempesta per il mio progetto corrente. Durante questo processo ho raccolto dati da queste risposte di gruppo e da github. Mentre alcune

5calore

2risposta

La tempesta riproduce la tupla quale elaborazione è scaduta?

È menzionato nella documentazione della tempesta, che la tempesta riproduce la tupla che l'elaborazione è scaduta. La mia domanda è se la tempesta lo fa automaticamente (senza chiamare fail() sul becc

45calore

4risposta

Test di bulloni e becchi di sfiato

Questa è una domanda di carattere generale relativa ai bulloni di test unità e ai beccucci in una topologia Storm scritta in Java. Qual è la pratica raccomandata e linee guida per l'unità-test (JUnit?

5calore

2risposta

Elaborazione ritardata coda/messaggio in Storm

Nella topologia Storm, durante l'elaborazione di uno stream, desidero ritardare l'elaborazione di alcuni messaggi fino ad alcuni punti futuri nel tempo. Quali sono alcune opzioni ragionevoli per farlo

7calore

2risposta

Utilizzo di Twitter Storm per elaborare i dati del registro?

Abbiamo un gran numero di applicazioni distribuite su molte macchine in più datacenter. Durante la giornata, riceveremo segnali (interni o esterni), che causano una cascata di eventi in ogni applicazi

10calore

1risposta

Confronto nei sistemi di calcolo cluster in memoria

Sto lavorando su Spark (Berkeley) Cluster Computing System. Durante le mie ricerche, ho appreso alcuni altri sistemi in-memory come Redis, Memcachedb, ecc. Sarebbe bello se qualcuno potesse darmi un c

5calore

2risposta

Storm> Howto Integrazione della callback Java in uno becco

Sto cercando di integrare Storm (see here) nel mio progetto. Io strappo i concetti di topologie, beccucci e bulloni. Ma ora, sto cercando di capire l'effettiva implementazione di alcune cose. A) Ho un

14calore

4risposta

Come inoltrare una topologia nel cluster di produzione tempesta utilizzando IDE

Sono di fronte a un problema Must submit topologies using the 'storm' client script so that StormSubmitter knows which jar to upload durante l'invio di una topologia a un cluster di produzione utilizz

10calore

2risposta

raggruppamento in una topologia tempesta semplice aggregazione

Sto cercando di scrivere una topologia che esegue le operazioni seguenti: un beccuccio che sottoscrive un feed Twitter (basata su una parola chiave) Un bullone di aggregazione che aggrega una serie di