在spring-xd get中使用分析模块创建流失败

Question

​

我正在开发spring-xd框架。我正在遵循Spring-XD guide Analytic标签，并希望为实时流数据部署我的预测模型。

我已经在R中使用naive-Bayes构建了虹膜分类模型，并将这个pmml文件存储在Ubuntu-14.0.4Lts的桌面上。这是我的流定义-

stream create test --definition "mqtt --url='tcp://localhost:1883' --topics='irisPayload'| analytic-pmml --location='/home/andy/Desktop/iris-flower-naive-bayes.pmml.xml' --inputFieldMapping='sepalLength:Sepal.Length,sepalWidth:Sepal.Width,petalLength:Petal.Length,petalWidth:Petal.Width'--outputFieldMapping='Predicted_Species:predictedSpecies' | file" --deploy
.

错误：-找不到分析和处理器模块。

我想我的流定义是错误的。因为我在spring-xd指南中找不到这种情况的流定义。

我在本地机器上的单节点上运行spring-xd。我希望使用MQTT Pub-Sub协议发送数据，而不是Http。我的MQTT代理已经启动并运行，任何形式的帮助都将不胜感激。非常感谢。

Answer 1

IIRC，由于许可问题，它没有随XD一起分发。

您可以使用find it on github here并自己构建/安装它。