概述
这里将使用Twitter流式数据,它符合所有所需:持续而且无止境的数据源。
Spark Streaming
Spark Streaming在电子书《手把手教你学习Spark》第六章有详细介绍,这里略过Streaming API的详细介绍,直接进行程序开发 。
程序开发设置部分
程序开发起始部分需要做好准备工作。
val config = new SparkConf().setAppName("twitter-stream-sentiment")val sc = new SparkContext(config)sc.setLogLevel("WARN")\val ssc = new StreamingContext(sc, Seconds(5))\System.setProperty("twitter4j.oauth.consumerKey
最后
以上就是笨笨雪糕为你收集整理的使用Spark Streaming进行情感分析的全部内容,希望文章能够帮你解决使用Spark Streaming进行情感分析所遇到的程序开发问题。
如果觉得靠谱客网站的内容还不错,欢迎将靠谱客网站推荐给程序员好友。
本图文内容来源于网友提供,作为学习参考使用,或来自网络收集整理,版权属于原作者所有。
发表评论 取消回复