mapreduce

14calore

3risposta

Come usare la mappa di Cassandra Ridurre con o senza maiale?

Qualcuno può spiegare come funziona MapReduce con Cassandra .6? Ho letto l'esempio di conteggio delle parole, ma non seguo esattamente ciò che sta accadendo sul lato di Cassandra contro il termine "cl

22calore

5risposta

Eseguire il lavoro Hadoop senza utilizzare JobConf

Non riesco a trovare un singolo esempio di invio di un lavoro Hadoop che non utilizza la classe deprecata JobConf. JobClient, che non è stato deprecato, supporta ancora solo i metodi che accettano un

6calore

3risposta

Map Reduce Frameworks/Infrastructure

Map Reduce è uno schema che sembra avere molta trazione ultimamente e comincio a vederlo manifest in uno dei miei progetti focalizzato su una pipeline di elaborazione eventi (iPhone Accelerometer e da

20calore

1risposta

Uso della mappa di MongoDB/riduzione a "raggruppa per" due campi

Ho bisogno di qualcosa di leggermente più complesso degli esempi nei documenti MongoDB e non riesco a riuscire a capirlo. Dire che ho una collezione di oggetti della forma {date: "2010-10-10", type: "

7calore

5risposta

Debug di applicazioni hadoop

Ho provato a stampare i valori utilizzando System.out.println(), ma non appariranno sulla console. Come posso stampare i valori in una mappa/ridurre l'applicazione per il debugging usando Hadoop? Graz

35calore

2risposta

Differenza tra Fork/Join e Map/Reduce

Qual è la differenza principale tra Fork/Join e Map/Reduce? Differiscono nel tipo di scomposizione e distribuzione (dati rispetto al calcolo)?

9calore

4risposta

Qual è il modo migliore per contare i visitatori unici con Hadoop?

Ciao a tutti, appena iniziato su Hadoop e curioso quello che il modo migliore di MapReduce sarebbe quello di contare i visitatori unici, se i tuoi file di log si presentava così ... DATE siteID actio

7calore

1risposta

Disco/MappaRiduce: Utilizzo dei risultati della precedente iterazione come input per una nuova iterazione

Attualmente sto implementando PageRank su Disco. Come un algoritmo iterativo, i risultati di un'iterazione vengono utilizzati come input per l'iterazione successiva. Ho un file di grandi dimensioni ch

10calore

4risposta

Variabili globali in hadoop

Il mio programma segue una mappa iterativa/approccio di riduzione. E ha bisogno di fermarsi se sono soddisfatte determinate condizioni. È comunque possibile impostare una variabile globale che può ess

6calore

3risposta

Più righe di testo in una singola mappa

Ho cercato di utilizzare Hadoop per inviare N quantità di linee a una singola mappatura. Non ho bisogno che le linee siano già divise. Ho provato a utilizzare NLineInputFormat, tuttavia questo invia N