Re: column expression in left outer join for DataFrame

2015-03-25 Thread S Krishna
th that your > query is still ambiguous and you will need to use aliases: > > val df_1 = df.filter( df("event") === 0) > . select("country", "cnt").as("a") > val df_2 = df.filter( df("event") === 3) >

Re: column expression in left outer join for DataFrame

2015-03-24 Thread S Krishna
Hi, Thanks for your response. I modified my code as per your suggestion, but now I am getting a runtime error. Here's my code: val df_1 = df.filter( df("event") === 0) . select("country", "cnt") val df_2 = df.filter( df("event") === 3) . select("country", "cnt

Re: Spark Streaming: Sentiment Analysis of Twitter streams

2014-10-15 Thread S Krishna
Hi, I am using 1.1.0. I did set my twitter credentials and I am using the full path. I did not paste this in the public post. I am running on a cluster and getting the exception. Are you running in local or standalone mode? Thanks On Oct 15, 2014 3:20 AM, "Akhil Das" wrote: > I just ran the sam