Example 1 – Get hashtags from Twitter
{"Image DocumentName": "Example 1 \u2013 Get hashtags from Twitter", "Image ImageDescription": "val tweets = ssc.twitterStream(<Twitter username>, <Twitter password>) val hashTags = tweets.flatMap (status => getTags(status)) hashTags.saveAsHadoopFiles( hdfs://... ) output operation: to push data to external storage. t. t+1. t+2. tweets DStream. flatMap. flatMap. flatMap. hashTags DStream. save. every batch saved to HDFS.", "Image XResolution": "37", "Image YResolution": "37", "Image ResolutionUnit": "Pixels/Centimeter", "Image Software": "SlidePlayer", "Image YCbCrPositioning": "Centered"}