Look at the method pipe http://spark.apache.org/docs/latest/api/scala/index.html#org.apache.spark.rdd.RDD
On Wed, Jan 14, 2015 at 11:16 PM, umanga <bistauma...@gmail.com> wrote: > This is question i originally asked in Quora: http://qr.ae/6qjoI > > We have some code written in C++ and Python that does data enrichment to > our > data streams. If i use Storm, i could use those code with some small > modifications using ShellBolt and IRichBolt. Since the functionalities is > all about data enrichment, if the code has been in Scala, i could use it > with rdd.map() function. So, is there any way to use non scala existing > code > in map with spark streaming in scala like Storm’s ShellBolt and IRichBolt? > > umanga, > kathmandu > > > > -- > View this message in context: > http://apache-spark-user-list.1001560.n3.nabble.com/Is-there-Spark-s-equivalent-for-Storm-s-ShellBolt-tp21146.html > Sent from the Apache Spark User List mailing list archive at Nabble.com. > > --------------------------------------------------------------------- > To unsubscribe, e-mail: user-unsubscr...@spark.apache.org > For additional commands, e-mail: user-h...@spark.apache.org > >
