Suchergebnisse für Anfrage "hadoop"
Wie wird ein Reduzierer zum Senden von <Text, IntWritable> und ein Mapper zum Empfangen von <Text, IntWritable> festgelegt?
Ich entwickle Code für hadoop mitKarte verkleiner das benutztzwei Mapper und zwei Reduzierer. Ich wurde angewiesen, @ zu verwend SequenceFileInputFormat und SequenceFileOutputFormat, damit die Ausgabe des ersten Reduzierers und die Eingabe des ...
NLineInputFormat funktioniert nicht in Spark
Was ich möchte, ist im Grunde, dass jedes Datenelement aus 10 Zeilen besteht. Mit dem folgenden Code besteht jedes Element jedoch noch aus einer Zeile. Welchen Fehler mache ich hier? val conf = new SparkConf().setAppName("MyApp") ...
Das Root-Scratch-Verzeichnis: / tmp / hive unter HDFS sollte beschreibbar sein. Aktuelle Berechtigungen sind: -wx ------
Ich habe die Berechtigung mit dem Befehl hdfs geändert. Trotzdem wird derselbe Fehler angezeigt. Das Root-Scratch-Verzeichnis: / tmp / hive unter HDFS sollte beschreibbar sein. Aktuelle Berechtigungen sind: -wx ------ Java Programm, das ich ...