mapreduce

7calore

2risposta

In che modo Apache Flink è paragonabile a Mapreduce su Hadoop?

In che modo Apache Flink è paragonabile a Mapreduce su Hadoop? In che modo è migliore e perché?

8calore

2risposta

Perché errore memoria spazio java heap YARN?

Voglio provare ad impostare la memoria in YARN, quindi proverò a configurare alcuni parametri su yarn-site.xml e mapred-site.xml. Dal modo in cui utilizzo hadoop 2.6.0. Ma ottengo un errore quando ese

5calore

1risposta

Hadoop scrive su un nuovo file dal programma di mappatura

Sto provando a scrivere un programma che richiede un enorme set di dati e quindi esegue alcune query su di esso utilizzando mapreduce. Ho un codice come questo: public static class MRMapper exten

5calore

4risposta

array_reduce() non può funzionare come "riduttore" di array associativi per PHP?

Ho un array associativo $assoc, e la necessità di ridurre a una stringa, in questo contesto $OUT = "<row"; foreach($assoc as $k=>$v) $OUT.= " $k=\"$v\""; $OUT.= '/>'; Come fare in an elegant way l

7calore

3risposta

Impossibile trovare o caricare la classe principale com.sun.tools.javac.Main hadoop mapreduce

Sto cercando di imparare MapReduce ma sono un po 'perso in questo momento. http://hadoop.apache.org/docs/r2.6.0/hadoop-mapreduce-client/hadoop-mapreduce-client-core/MapReduceTutorial.html#Usage In par

8calore

1risposta

Quando utilizzare la mappa riduci su Pipeline di aggregazione in MongoDB?

Guardando documentation per la cartografia di ridurre, ho scoperto che: NOTA: Per la maggior parte delle operazioni di aggregazione, l'aggregazione Pipeline fornisce migliori prestazioni e un'interfac

5calore

2risposta

Interfaccia trovata org.apache.hadoop.mapreduce.TaskAttemptContext

Non ho ancora visto una soluzione al mio particolare problema. Non funziona almeno. Mi sta facendo diventare pazzo. Questa particolare combo non sembra avere molto nello spazio di google. Il mio error

5calore

1risposta

Hadoop 2.4.0 in streaming opzioni parser generico utilizzando TAB come separatore

So che la scheda è separatore di input predefinito per i campi: stream.map.output.field.separator stream.reduce.input.field.separator stream.reduce.output.field.separator mapreduce.textoutputformat

8calore

1risposta

Come posso leggere da un'istanza di HBase ma scrivere ad un altro?

Attualmente ho due tabelle Hbase (le chiamiamo tableA e tableB). Utilizzando un lavoro MapReduce a una sola fase, i dati in tableA vengono letti e elaborati e salvati in tableB. Attualmente entrambe l

11calore

2risposta

Hadoop Mapper non funziona a causa del "Contenitore ucciso da ApplicationMaster"

Sto provando ad eseguire una mappa per ridurre il programma su Hadoop. Quando invio il lavoro al cluster di nodo singolo hadoop. Il lavoro viene sempre creato ma non riuscendo con il messaggio "Contai