spark-streaming-demo

【文件属性】：

文件名称：spark-streaming-demo

文件大小：181KB

文件格式：ZIP

更新时间：2024-07-11 15:27:06

Scala

此演示处理 Meetup.com RSVP 流并将结果存储在 Cassandra 中。 此应用程序的主要目的是演示和 DSE 中的 Spark Streaming 功能。 它产生两种类型的结果： 每个国家/地区的与会者总数（自申请开始以来）。 每 5 秒刷新一次。 显示简单的流处理功能。 最近 5 分钟内的热门聚会主题。 每 10 秒刷新一次。 显示窗口转换功能。 包含 Web 仪表板以可视化这些结果： 实时 RSVP 流可通过。 流处理 在本地启动流处理： git clone [e-mail]:rstml/datastax-spark-streaming-demo.git cd datastax-spark-streaming-demo sbt assembly run 在 DSE 集群上部署 Spark 应用程序： dse spark-submit --c

【文件预览】：
spark-streaming-demo-master
----readme.md(2KB)
----screenshot.png(146KB)
----src()
--------main()
----.gitignore(227B)
----web()
--------sbt(14KB)
--------src()
--------.gitignore(756B)
--------project()
--------README.md(195B)
----project()
--------assembly.sbt(58B)
--------StreamingDemoBuild.scala(5KB)
--------build.properties(19B)
----LICENSE.txt(11KB)