Created a twitter stream using the stream api provided by tweepy. Consumed the stream in spark using the spark streaming API.