Thank you Jakob. I will try as suggested.
Regards,
Shashi
On Fri, Sep 23, 2016 at 12:14 AM, Jakob Odersky wrote:
> Hi Shashikant,
>
> I think you are trying to do too much at once in your helper class.
> Spark's RDD API is functional, it is meant to be used by writing many
> little transformati
Hi Shashikant,
I think you are trying to do too much at once in your helper class.
Spark's RDD API is functional, it is meant to be used by writing many
little transformations that will be distributed across a cluster.
Appart from that, `rdd.pipe` seems like a good approach. Here is the
relevant
Hello Jakob,
Thanks for replying. Here is a short example of what I am trying. Taking an
example of Product column family in Cassandra just for explaining my
requirement
In Driver.java
{
JavaRDD productsRdd = Get Products from Cassandra;
productsRdd.map(ProductHelper.processProd
Can you provide more details? It's unclear what you're asking
On Wed, Sep 21, 2016 at 10:14 AM, shashikant.kulka...@gmail.com
wrote:
> Hi All,
>
> I am trying to use the JavaRDD.pipe() API.
>
> I have one object with me from the JavaRDD
---
w if you need more inputs from me.
Thanks in advance.
Shashi
--
View this message in context:
http://apache-spark-user-list.1001560.n3.nabble.com/Apache-Spark-JavaRDD-pipe-need-help-tp27772.html
Sent from the Apache Spark User List mailing list archive at Nabble.com.