spark-streaming-exercises:Spark Streaming练习的骨架

时间:2024-05-25 12:24:00
【文件属性】:

文件名称:spark-streaming-exercises:Spark Streaming练习的骨架

文件大小:17KB

文件格式:ZIP

更新时间:2024-05-25 12:24:00

Java

火花流练习 该项目提供了一组实用程序,以便使用Spark Streaming开发不同的练习。 当前,该项目仅包含一个日志事件生成器。 事件产生器 事件生成器通过常见的OS套接字以纯文本格式生成一系列日志事件。 该组件背后的思想是基于经典auth.log和access.log的内容来模拟两个日志信息源。 通过指定要经历的迭代次数以及每次迭代的成功和失败日志条目数来配置生成器。 这允许侦听的Spark Streaming开发不同的解决方案,以确定哪些流量应触发警报。 要将事件生成器与默认选项一起使用,请执行: mvn compile exec:java -Dexec.mainClass=org.spark.examples.events.EventGenerator 此外,您可以使用自定义选项启动生成器。 mvn compile exec:java -Dexec.mainClass=o


【文件预览】:
spark-streaming-exercises-master
----.gitignore(20B)
----src()
--------main()
----LICENSE(11KB)
----pom.xml(4KB)
----README.md(4KB)

网友评论