怎么用Eclipse开发Spark2.0

小编给大家分享一下怎么用Eclipse开发Spark2.0，相信大部分人都还不怎么了解，因此分享这篇文章给大家参考一下，希望大家阅读完这篇文章后大有收获，下面让我们一起去了解一下吧！

成都创新互联主要从事成都做网站、网站建设、网页设计、企业做网站、公司建网站等业务。立足成都服务宿州,10多年网站建设经验,价格优惠、服务专业,欢迎来电咨询建站服务:13518219792

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 控制台会输出结果