首页投稿(暂停使用,暂停投稿)程序员

Markdown 使用练习

2016-05-18  本文已影响759人  海纳百川_spark

Markdown练习

无序列表

有序列表

  1. 你好
  2. 我好
  3. 他好

这里表示引用的内容
换行

百度 超链接

图片

斜体
粗体
删除线
表格

header 1 header 2
row 1 col 1 row 1 col 2
row 2 col 1 row 2 col 2

代码块

objectNetworkWordCount {

    defmain(args:Array[String]) {
    if (args.length< 2) {
      System.err.println("Usage: NetworkWordCount<hostname> <port>")
      System.exit(1)
    }
    
    val sparkConf = newSparkConf().setAppName("NetworkWordCount").setMaster("local[2]")
    val ssc = newStreamingContext(sparkConf,Seconds(1))
    val lines= ssc.socketTextStream(args(0), args(1).toInt,StorageLevel.MEMORY_AND_DISK_SER)
    val words= lines.flatMap(_.split(""))
    val wordCounts= words.map(x => (x,1)).reduceByKey(_ + _)
    wordCounts.print()
    ssc.start()
    ssc.awaitTermination()
    }
}
上一篇下一篇

猜你喜欢

热点阅读