Jaonary
val loadedData: RDD[(String,(String,Array[Byte]))] =
sc.objectFile("yourObjectFileName")
Deenar
--
View this message in context:
http://apache-spark-user-list.1001560.n3.nabble.com/Reload-RDD-saved-with-saveAsObjectFile-tp2943p3009.html
Sent from the Apache Spark
Hi all,
I have an RDD[(String,(String,Array[Byte]))] that I save into sequence file
with "saveAsObjectFile". At the end, Spark writes a sequence file of
(NullWritable, BytesWritable). How to get back my tuple of
(String,(String,Array[Bytes]) ?
Any ideas will be helpfull.
Cheers,
Jaonary