本文主要是介绍SparkStreaming 打印输出demo,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!
- 1.nc -lk 9999
-l 使用监听模式,管控传入的资料。
本机开启9999端口
一个server对应一个client,多了可能出问题,也就是下次起sparkstreaming任务时,必须先关了这个端口,重开
- 2.提交sparkstreaming任务
package com.streamingimport org.apache.spark.streaming.Seconds
import org.apache.spark.streaming.StreamingContext
import org.apache.spark.SparkConfobject Socket
{def main(args:Array[String]){val sc = ne
这篇关于SparkStreaming 打印输出demo的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!