Ich möchte Hadoop Map / Reduce-Jobs in Go schreiben (und nicht die Streaming API!).
Ich habe versucht, hortonworks / gohadoop und colinmarc / hdfs , aber ich sehe immer noch nicht, wie man Jobs real schreibt. Ich habe nach GitHub-Codes gesucht, die diese Module importieren, aber anscheinend gibt es nichts Relevantes.
Gibt es WordCount.go irgendwo?
Hier ist eine einfache Implementierung von Map / Reduce, geschrieben in Golang (verfügbar unter github):
Dieser Github: Ссылка ist ein gutes Beispiel für die Verwendung eines Golang-Jobs in Hadoop:
Jist:
%Vor%Das Skript wird gestartet:
%Vor%