Re: Issue with Spark Twitter Streaming

hey, did you manage to solve the problem? I have exactly the same problem and I am not able to solve it. Thank you! -- Sent from: http://apache-spark-user-list.1001560.n3.nabble.com/ - To unsubscribe e-mail:

Spark-twitter Streaming

Hello everyone, This is in reference to spark-twitter streaming. val stream = TwitterUtils.createStream(ssc, None) can anybody tell me why this dstream is no a proper JSON object as I am not able to parse it further. spark-version = 2.0.1 spark-api =scala streaming jar = org.apache.bahir

Re: Spark Twitter streaming

Do you mean listening to the twitter stream data? Maybe you can use the Twitter Stream API or Twitter Search API for this purpose. Imre On Tue, Mar 8, 2016 at 2:54 PM, Soni spark wrote: > Hallo friends, > > I need a urgent help. > > I am using spark streaming to get

Spark Twitter streaming

Hallo friends, I need a urgent help. I am using spark streaming to get the tweets from twitter and loading the data into HDFS. I want to find out the tweet source whether it is from web or mobile web or facebook ..etc. could you please help me logic. Thanks Soniya

Re: Spark twitter streaming in Java

> > I am struggling with spark twitter streaming. I am not getting any data. > Please correct below code if you found any mistakes. > > import org.apache.spark.*; > import org.apache.spark.api.java. > function.*; > import org.apache.spark.streaming.*; > import org.apache.

Spark twitter streaming in Java

Dear Friends, I am struggling with spark twitter streaming. I am not getting any data. Please correct below code if you found any mistakes. import org.apache.spark.*; import org.apache.spark.api.java. function.*; import org.apache.spark.streaming.*; import org.apache.spark.streaming.api.java

Issue with Spark Twitter Streaming

All, We are using Spark Streaming to receive data from twitter stream. This is running behind proxy. We have done the following configurations inside spark steaming for twitter4j to work behind proxy. def main(args: Array[String]) { val filters = Array(Modi)