【文件属性】：
文件名称：word源码java-marceline:Storm/Trident的ClojureDSL
文件大小：43KB
文件格式：ZIP
更新时间：2021-06-05 22:26:47
系统开源
word源码java
玛瑟琳
Marceline
是一个
Clojure
DSL，用于
.
内容
概述
这允许有状态的流处理和分布式查询。
Marceline
提供了一个
DSL，允许您定义
Trident
必须从
Clojure
提供的所有原语。
准备好？
抓住你愿意的船只，让我们这样做！
安装
Marceline
可从
clojars
获得。
将以下内容添加到项目的deps
。
[yieldbot/marceline
"0.3.1-SNAPSHOT"]
请注意，marceline
与与
Storm
的
clojure
版本兼容的
clojure
版本挂钩；
目前是1.7.0
。
流
.
在这个例子中，我们使用了一个FixedBatchSpout
，它将发出无限的句子流：
(
ns
com.black.magic.level-eight-evil-topology
(
:require
[marceline.storm.trident
:as
t])
(
:import
[org.apache.storm.trident.testing
FixedBatchSpout]))
(
de
【文件预览】：
marceline-master
----LICENSE.html(12KB)
----.gitignore(188B)
----src()
--------jvm()
--------clj()
----CHANGELOG.md(176B)
----README.md(19KB)
----test()
--------marceline()
----project.clj(534B)