weka - Apache SAMOA 分析拓扑

Question

是否有任何示例、教程、博客、书籍、视频以及任何可以向我展示如何使用 Apache SAMOA 创建拓扑的东西？

我对将 SAMOA 用于 Storm 非常感兴趣，我想构建一个拓扑，其中拓扑的一部分执行一些聚类（或关联规则），但我什至找不到一个例子来做到这一点。谁能解释如何做到这一点？甚至可能吗？

Answer 1

为了使用 STORM 在 SAMOA 上工作，您应该首先安装和配置 STORM。
STORM 拓扑有几个工作节点，它们是 nimbus、zookeeper、supervisor。这些worker可能驻留在不同的机器上，所以，一开始，我建议你使用wirbelsturm，它可以帮助你轻松地为拓扑设置虚拟机。

我的安装步骤是；

- 流浪者 1.7.2+
- 虚拟机 4.3.x
- 平行
- Storm 0.9.3（发布和代码库）
- 旋风风暴

！！版本对我来说非常重要，因为我无法使用最新版本。

在 SAMOA 你应该编译和打包 STORM，

# Build Storm
$ cd storm
$ mvn clean install -DskipTests=true

# Build the storm-starter example
$ cd examples/storm-starter
$ mvn compile exec:java -Dstorm.topology=storm.starter.WordCountTopology
$ mvn package

最后，不要忘记更改配置文件；

- 流浪文件
- wirbelsturm.yaml
- 主机

在 SAMOA 上运行时；

$ bin/samoa storm target/SAMOA-Storm-0.4.0-incubating-SNAPSHOT.jar "PrequentialEvaluation -d /tmp/dump.csv -i 1000000 -f 100000 -l (org.apache.samoa.learners.classifiers.trees.VerticalHoeffdingTree -p 4) -s (org.apache.samoa.moa.streams.generators.RandomTreeGenerator -c 2 -o 10 -u 10)"

如果您的安装和配置正确，您应该会在 Storm UI 上看到您的拓扑：http://localhost:28080/

更多详细信息；

• 执行-SAMOA-with-Apache-Storm
• 运行多节点风暴集群
• wirbelsturm#how-it-works
• wirbelsturm-一键部署-storm-kafka-clusters-with-vagrant-puppet

我希望这有帮助。