RDD [OmnitureData] in S3 schreiben

Question

Ich habe eine RDD, die Objekttypen meiner benutzerdefinierten Klasse OmnitureData enthält. OmnitureData-Daten enthalten 1000 von Datenvariablen. Ich möchte die Daten in S3 schreiben.

data: RDD[OmnitureData] 
data.saveAsTextFile(path) 

In S3 Ich sehe Daten wie:

OmnitureFeedOutputEntry@5655c68b 
OmnitureFeedOutputEntry@kgfwe77c 
OmnitureFeedOutputEntry@4rjkks8f 
OmnitureFeedOutputEntry@57bfgk6d 
OmnitureFeedOutputEntry@646lk6sd 

Wie kann ich speichern sie in einer Weise, dass ich die aktuellen Daten von OmnitureData Mitglieder sehen können?

Answer 1

Die Lösung gefunden.

def writeOnS3(data: RDD[OmnitureFeedOutputEntry], path: String)= { 
try { 
    val finalData: RDD[String] = data.map(x => { 
    implicit val formats = Serialization.formats(NoTypeHints) 
    write(x)}) 
    finalData.saveAsTextFile(path) 
    logger.info("task=writeOnS3, status=success") 
} catch { 
    case e: Exception => logger.error("task=writeOnS3, status=failure") 
} 

}