共计 1403 个字符，预计需要花费 4 分钟才能阅读完成。
丸趣 TV 小编给大家分享一下怎么用 Eclipse 开发 Spark2.0，相信大部分人都还不怎么了解，因此分享这篇文章给大家参考一下，希望大家阅读完这篇文章后大有收获，下面让我们一起去了解一下吧！
1. 首先我用的是 scala 版本的 ide. 这个可以去官网下载。先介绍下我的版本：hadoop2.7.2+spark2.0+scala2.11+java1.7
首先打开 eclipse，设置好 workspace 后，就能开始开发了
2. 新建 scala Project . 起个项目的名字
3. 新建个 scala object . 开始写代码
注意需要导入相关的包。主要有 scala 的包还有 spark 的包，spark 需要的包主要在 spark 安装目录下的 jar 文件下的所有包
4. 废话少说，直接上代码
object TestSparkStreaming {
def main(args: Array[String]): Unit = {
import org.apache.spark._
import org.apache.spark.streaming._
import org.apache.spark.streaming.StreamingContext._ // not necessary since Spark 1.3
// Create a local StreamingContext with two working thread and batch interval of 1 second.
// The master requires 2 cores to prevent from a starvation scenario.
val conf = new SparkConf().setMaster( local[2] ).setAppName(NetworkWordCount)
val ssc = new StreamingContext(conf, Seconds(5))
val lines = ssc.socketTextStream(master , 9999)
// val lines = ssc.textFileStream(/home/usr/temp/)
val words = lines.flatMap(_.split())
import org.apache.spark.streaming.StreamingContext._ // not necessary since Spark 1.3
// Count each word in each batch
val pairs = words.map(word = (word, 1))
val wordCounts = pairs.reduceByKey(_ + _)
// Print the first ten elements of each RDD generated in this DStream to the console
wordCounts.print()
ssc.start() // Start the computation
ssc.awaitTermination()
}
}
5. 在 linux 终端连上 9999 端口 nc-lk 9999
输入一些单词
6. 可以看到 eclipse 的控制台会输出结果
以上是“怎么用 Eclipse 开发 Spark2.0”这篇文章的所有内容，感谢各位的阅读！相信大家都有了一定的了解，希望分享的内容对大家有所帮助，如果还想学习更多知识，欢迎关注丸趣 TV 行业资讯频道！
