What would it mean to make a DStream into a String? it's inherently a
sequence of things over time, each of which might be a string but
which are usually RDDs of things.
On Wed, Oct 29, 2014 at 11:15 PM, Harold Nguyen <har...@nexgate.com> wrote:
> Hi all,
>
> How do I convert a DStream to a string ?
>
> For instance, I want to be able to:
>
> val myword = words.filter(word => word.startsWith("blah"))
>
> And use "myword" in other places, like tacking it onto (key, value) pairs,
> like so:
>
> val pairs = words.map(word => (myword+"_"+word, 1))
>
> Thanks for any help,
>
> Harold
>
>
>
>
---------------------------------------------------------------------
To unsubscribe, e-mail: user-unsubscr...@spark.apache.org
For additional commands, e-mail: user-h...@spark.apache.org
