mapreduce

18calore

2risposta

Ho cercato di utilizzare MapReduce in MongoDB per fare ciò che ritengo sia una procedura semplice. Non so se questo sia l'approccio giusto, se dovessi usare anche MapReduce. Ho cercato su Google le pa

5calore

1risposta

Moltiplicazione matrice Hadoop

Stavo eseguendo il programma di moltiplicazione MapReduce Matrix trovato a http://www.norstad.org/matrix-multiply/index.html. Ho scoperto che questa implementazione non funziona correttamente quando c

18calore

3risposta

identityreducer nella nuova API Hadoop

Ho trascorso quasi un giorno ma non sono riuscito a capire come utilizzare IdentityReducer nella nuova API Hadoop. Tutti i riferimenti o le classi che posso trovare sono con la vecchia API. E ovviamen

6calore

1risposta

Come unire le raccolte MongoDB in Python?

Come partecipare (in un senso di INNER JOIN da SQL) due raccolte MongoDB in Python? Devo usare la mappa nativa/ridurre il codice javascript o farlo in PyMongo? Come risolvere questo con meno codice?

5calore

2risposta

Qual è il modo corretto di utilizzare oozie per scrivere su più flussi di output per un lavoro mapreduce?

Sto utilizzando la nuova API Hadoop per scrivere una sequenza di lavori di riduzione della mappa. Intendo utilizzare Oozie per eseguire il pipeline di tutti questi elementi insieme, ma non riesco a tr

7calore

1risposta

Scala/Hadoop: specificare il contesto per il riduttore

Prima di saltare a giocare con Scoobi o Scrunch, ho pensato di provare a eseguire il porting di WordCount su scala (2.9.1) utilizzando solo i collegamenti java di Hadoop (0.20.1). In origine, ho avuto

15calore

2risposta

Differenza nella chiamata del lavoro

Qual è la differenza tra chiamare un lavoro di ridimensionamento di mappe da main() e da ToolRunner.run()? Quando diciamo che la classe principale dice, MapReduce extends Configured implements Tool, q

7calore

3risposta

rotto Errore tubo provoca lo streaming di lavoro elastico MapReduce su AWS a fallire

Tutto funziona bene a livello locale quando lo faccio nel modo seguente: cat input | python mapper.py | sort | python reducer.py Tuttavia, quando si esegue il lavoro di streaming MapReduce su AWS El

6calore

3risposta

Utilizzo del parametro 'limite' in CouchDB Visualizza funzione mappa

Sono consapevole che tramite l'API REST, è possibile specificare il parametro 'limite' (ad esempio? Limite = 5) per limitare il numero di risultati restituiti da una determinata vista in CouchDB. La m

9calore

3risposta

NSArray. Come posso implementare la funzione Mappa?

In iOS voglio implementare la funzione mappa per NSArray. Questa è una funzione che viene applicata a ogni elemento dell'array. Qual è il modo migliore per implementarlo? Grazie, Doug