Re: Creating RDDs from within foreachPartition() [Spark-Streaming]

2015-02-18 Thread Sean Owen
s the StreamingContext object created in the main function, outside of > /foreachPartition/) then I get a NotSerializableException. > > What is the correct way to do this ? > > > > -- > View this message in context: > http://apache-spark-user-list.1001560.n3.nabble.com/Creating-RDDs

Creating RDDs from within foreachPartition() [Spark-Streaming]

2015-02-18 Thread t1ny
correct way to do this ? -- View this message in context: http://apache-spark-user-list.1001560.n3.nabble.com/Creating-RDDs-from-within-foreachPartition-Spark-Streaming-tp21700.html Sent from the Apache Spark User List mailing list