本文来自博客园,由火龙果软件Anna编辑、推荐。1.1.1流数据说明在实例演示中模拟实际情况,需要源源不断地接入流数据,为了在演示过程中更接近真实环境将定义流数据模拟器。该模拟器主要功能:通过Socket方式监听指定的端口号,当外部程序通过该端口连接并请求数据时,模拟器将定时将指定的文件数据随机获取发送给外部程序。1.1.2模拟器代码 1.1.3生成打包文件【注】可以参见第3课《Spark编程模型(下)--IDEA搭建及实战》进行打包在打包配置界面中,需要在ClassPath加入:/app/scala-2.10.4/lib/scala-swing.jar/app/scala-2.10.4/li
1