distributed

25calore

5risposta

Le funzioni di Haskell possono essere serializzate?

Il modo migliore per farlo sarebbe ottenere la rappresentazione della funzione (se può essere recuperata in qualche modo). La serializzazione binaria è preferita per motivi di efficienza. Penso che ci

5calore

1risposta

RMI Java: qual è il ruolo dello stub-scheletro generato dal compilatore rmic

Attualmente sto imparando Java RMI (Remote Method Invocation) e ho seguito il tutorial fornito da Oracle sul suo sito web. Tuttavia, ho una domanda specifica: Qual è l'utilizzo dello stub-scheletro ge

5calore

1risposta

Priorità attività in sedano con redis

Vorrei implementare un sistema di esecuzione del lavoro distribuito con sedano. Dato che rabbitMQ non supporta le priorità e ho dolorosamente bisogno di questa funzione, mi sono rivolto a sedici + red

5calore

3risposta

Come impostare il numero del riduttore in modo dinamico in base alla dimensione dell'output del mio mapper?

So che il numero di mapper può essere impostato in base alla mia dimensione divisa dfs impostando mapred.min.split.size su dfs.block.size. Analogamente, come è possibile impostare il numero di ridutto

6calore

1risposta

Funzionamento della finestra Streaming Spark

Quanto segue è un codice semplice per ottenere il conteggio delle parole su una dimensione della finestra di 30 secondi e dimensioni della diapositiva di 10 secondi. import org.apache.spark.SparkConf

5calore

1risposta

Spark 1.0.2 (anche 1.1.0) si blocca su una partizione

Ho uno strano problema nella scintilla di apache e gradirei un po 'di aiuto. Dopo aver letto i dati da hdfs (e facendo una conversione da json a object) la fase successiva (elaborazione di detti ogget

5calore

1risposta

Come funziona il rilevamento dei nodi terminati in Erlang? In che modo net_ticktime influenza il controllo della vividezza dei nodi in Erlang?

Ho impostato il valore net_ticktime su 600 secondi. net_kernel:set_net_ticktime(600) Nella documentazione Erlang per net_ticktime = TickTime: Specifica il net_kernel spuntare tempo. TickTime è dato

9calore

1risposta

sincronizzazione server zookeeper vs redis

Ho un piccolo gruppo di server che devo tenere sincronizzati. Il mio pensiero iniziale su questo era quello di avere un server "master" e pubblicare aggiornamenti usando la funzionalità pub/sub di red

16calore

1risposta

Redis, distribuiti o no?

Domanda 1: So che Redis carica tutti i dati in memoria, migliorando così la velocità di lettura/scrittura. Quindi, vuol dire che se la mia dimensione della memoria è 2G, la dimensione massima del set

8calore

2risposta

Come decidere le dimensioni di Kafka Cluster

Sto pensando di stabilire quanti nodi devono essere presenti su Kafka Cluster. Non sono sicuro dei parametri da tenere in considerazione. Sono sicuro che deve essere> = 3 (con fattore di replicazione