Hello, I am debugging my code to find out what else to cache.
Following is a line in log: 14/10/16 12:00:01 INFO TransformedDStream: Persisting RDD 6 for time 1413486000000 ms to StorageLevel(true, true, false, false, 1) at time 1413486000000 ms Is there a way to name a DStream? RDD has a name method, but DStream does not. Please let me know if there a way to map the DStream to a location in my source. Thanks, -Soumitra. --------------------------------------------------------------------- To unsubscribe, e-mail: user-unsubscr...@spark.apache.org For additional commands, e-mail: user-h...@spark.apache.org
