温馨提示×

怎么用Eclipse开发Spark2.0

发布时间:2021-11-27 10:54:23 来源:亿速云 阅读:92 作者:小新 栏目:云计算

小编给大家分享一下怎么用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控制台会输出结果

以上是“怎么用Eclipse开发Spark2.0”这篇文章的所有内容,感谢各位的阅读!相信大家都有了一定的了解,希望分享的内容对大家有所帮助,如果还想学习更多知识,欢迎关注亿速云行业资讯频道!

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

免费拨打  400 100 2938 免费拨打 400 100 2938
24小时售后技术支持 24小时售后技术支持
返回顶部 返回顶部