文件名称：flambo-kafka-streaming-example:使用 flamboclojure 的 Spark Streaming Kafka WordCount 示例
文件大小：11KB
文件格式：ZIP
更新时间：2024-07-15 00:22:34
Clojure
flambo-kafka-streaming-example 火花。 卡夫卡。 流媒体。 弗兰博。 Clojure。 等等。 我一直想玩这个东西有一段时间了。 我是简单但有用的自包含示例的忠实粉丝，但我找不到一个，所以在这里，如果没有别的的话，为了后代。 希望这能让你滚动。 如果你看到任何奇怪的东西或者它不起作用，请告诉我，我会尽力为子孙后代修复它。 也看看。 这主要类似于 Spark Streaming Kafka 示例，但在 Clojure 中使用实现（显然）。 我还冒昧地包含Kafka 发布一些内容，因此您不必这样做。 这是您需要的： 看看。 Clojure 的线程优先宏与 flambo 的 Spark API 包装器相结合，使实际处理变得非常容易逐渐建立，您可以轻松地注释掉步骤并查看会发生什么而无需进行太多更改。 Clojure ftw。 如果您还没有可以指向的 zo
【文件预览】：
flambo-kafka-streaming-example-master
----project.clj(1KB)
----test()
--------flambo_kafka_streaming_example()
----resources()
--------data.txt(1KB)
----LICENSE(11KB)
----src()
--------flambo_kafka_streaming_example()
----doc()
--------intro.md(128B)
----.gitignore(99B)
----README.md(3KB)