Re: saveAsSequenceFile for DStream

2014-08-30 Thread Chris Fregly
sful proof was the following: > >> val rdd = sc.parallelize(Array(("a",2), ("b",3), ("c",1))) > >> rdd.saveAsSequenceFile("tachyon://.../123.sf2") > >> val rdd2 = sc.sequenceFile[String,Int]("tachyon://.../123.sf2") > >> > >> How can I do something similar with streaming? > >> > >> > >> > >> > >> -- > >> View this message in context: > http://apache-spark-user-list.1001560.n3.nabble.com/saveAsSequenceFile-for-DStream-tp10369.html > >> Sent from the Apache Spark User List mailing list archive at Nabble.com. >

Re: saveAsSequenceFile for DStream

2014-07-22 Thread Barnaby Falls
uot;,1))) >> rdd.saveAsSequenceFile("tachyon://.../123.sf2") >> val rdd2 = sc.sequenceFile[String,Int]("tachyon://.../123.sf2") >> >> How can I do something similar with streaming? >> >> >> >> >> -- >> View this message in context: >> http://apache-spark-user-list.1001560.n3.nabble.com/saveAsSequenceFile-for-DStream-tp10369.html >> Sent from the Apache Spark User List mailing list archive at Nabble.com.

Re: saveAsSequenceFile for DStream

2014-07-22 Thread Sean Owen
sc.parallelize(Array(("a",2), ("b",3), ("c",1))) > rdd.saveAsSequenceFile("tachyon://.../123.sf2") > val rdd2 = sc.sequenceFile[String,Int]("tachyon://.../123.sf2") > > How can I do something similar with streaming? > > > > >

saveAsSequenceFile for DStream

2014-07-21 Thread Barnaby
g similar with streaming? -- View this message in context: http://apache-spark-user-list.1001560.n3.nabble.com/saveAsSequenceFile-for-DStream-tp10369.html Sent from the Apache Spark User List mailing list archive at Nabble.com.