2016-05-06 18 views
0

In Hadoop Cascading Flow habe ich eine Reihe von Tupeln, die verarbeitet wird und schließlich habe ich in ein Ziel versenkt.Anhängen bestimmter Text auf Hadoop Cascading Flow

Jetzt ist meine Anforderung: Um diese Tupel in Zieldatei mit bestimmten definierten Konstante String-Werte am Anfang und am Ende zu sinken.

Zum Beispiel: ich folgende Eingabe haben Tupel

10|11|12|13|14|15|16|17|18|19|20 
20|21|22|23|24|25|26|27|28|29|30 
1|2|3|4|5|6|7|8|9|10 

Jetzt muss ich wie diese Ausgabe haben:

Certain data before those data 
10|11|12|13|14|15|16|17|18|19|20 
20|21|22|23|24|25|26|27|28|29|30 
1|2|3|4|5|6|7|8|9|10 
Certain data after those data 

Little bit i von Repository-Klasse gesucht DelimitedParser und seine Methoden wie joinLine, joinFirstLine aber fällig Zu schlechter Dokumentation kann ich nicht genau sagen.

Antwort

0

Es kann davon abhängen, was "Bestimmte Daten vor diesen Daten" bedeutet? Wenn Sie TextDelimited verwenden, können Sie die Headerwerte in der Senke ablegen. Standardmäßig werden Header-Werte nicht gemäß der Dokumentation geschrieben, daher müssen Sie sie aktivieren. Eine andere Sache zu erinnern ist, dass die Header-Werte die Ausgabefelder darstellen.

-Amit