初步推动，需要清理工作，很多
简单流媒体应用
测试Spark流媒体应用程序，以测试测试平台。
不，没有用于测试测试应用程序的应用程序测试。
它尝试连接到localhost：2222上的侦听套接字。 它期望用新行分隔的数字流。 它计算数字的数量及其总和。 计数和总和打印在控制台上。
批处理大小设置为5秒
跑步
从项目文件夹中使用sbt启动主类。
sbt run
试验台
测试台。 执行测试计划，即：根据Typesafe配置文件在套接字上推送数字。
它侦听端口2222，并接受多个并发连接。 在所有连接上发送相同的数据。
可以通过上的基本Web界面给出测试计划，也可以在命令行上以文件形式给出测试计划。
执行测试计划后，命令行工具将终止。 通过Web界面，可以连续运行多个测试计划。 如果新计划仍在运行，它将取代上一个计划。
测试计划如下所示：
sequence = [
{ ty
2022-04-13 10:35:29
5.85MB
1
使用pyspark的stream操作kafka时，需要用到的jar包
2022-04-06 02:48:09
296KB
1
使用pyspark的stream操作kafka时，需要用到的jar包
2022-04-06 02:48:08
9.98MB
1
Real Time Recommendations using Spark Streaming
2022-03-13 10:45:43
1.46MB
1