spring-xd

0熱度

1回答

如何註冊springxd源MQTT與彈簧XD到MQTT經紀人

我創造流如 - stream create mqtttestfile --definition "mqtt --url='tcp://localhost:1883' --topics='helloTopic' | file" --deploy 創建和部署新的數據流「mqtttestfile」。我還檢查了localhost：9393/admin-ui，流被成功創建和部署。 我的MQTT代理正在l

mqtt spring-xd paho 2017-03-04

---

0熱度

1回答

使用spring-xd中的分析模塊創建流創建失敗

我正在使用spring-xd框架。我正在關注Spring-XD guide Analytic選項卡，並希望爲直播數據部署我的預測模型。 我已經在R中使用naive-Bayes構建了虹膜分類模型，並將該pmml文件存儲在我的桌面上的Ubuntu-14.0.4 Lts中。這是我的流定義 - stream create test --definition "mqtt --url='tcp://local

r mqtt spring-xd 2017-03-09

---

0熱度

1回答

在Spring-XD analytic-pmml流上，通過mqtt broker發佈json數據錯誤？

這是我流的定義 - xd:>stream create test --definition "mqtt --url='tcp://localhost:1883' --topics='irisPayload'| analytic-pmml --location='/home/andy/Desktop/iris-flower-naive-bayes.pmml.xml' --inputFieldMapp

mqtt spring-xd 2017-03-11

---

0熱度

1回答

我們如何發送來自批量作業的Spring-xd shell命令

我試圖通過運行JobA重新啓動JobB。我試圖使用jobOperater.restart（），我沒有成功。我能夠通過「作業執行重新啓動--id 0」從xd-shell重新啓動作業B.我可以通過從JobA調用該命令來做類似的事情。謝謝你的建議。

spring spring-boot spring-batch spring-xd 2017-03-22

---

1熱度

1回答

春天XD - 在規劃環境地政司表達的邏輯運算符和過濾

我想創建這樣 file --outputType=text/plain --dir=someDir --mode=lines | filter --expression='payload.contains(\"request url\") AND payload.contains(\"request method\")' | log 過濾器，我就在控制檯上可視化包含request URL和re

filter spring-xd spring-el 2017-03-25

---

1熱度

1回答

SpringXD - 可以通過文件源掃描不同的目錄？

我已經這些目錄 |- Dad Dir |--- Son Dir 1 |---- file1.txt |---- file2.txt |--- Son Dir 2 |---- file3.txt 它是不可能性與單個流，使用File Source，推斷的file*.txt例如內容，在輸入給Dad Dir

spring spring-xd 2017-03-28

---

2熱度

2回答

如何將郵件從kafka-sink發送到多個主題

我有一個帶有http-outbound-gateway的spring-xd http處理器模塊，它有一個errorChannel和outputChannel。任何帶有HTTP 200的消息都會發送到outputChannel，其餘的消息會落在failureChannel中。 現在，http處理器模塊通過帶有TopicX的kafka出站適配器連接到Kafka-Sink。 TopicX僅接收HTTP

apache-kafka spring-integration spring-xd kafka-producer-api 2017-03-28

---

0熱度

1回答

春XD 1.3.1流與卡桑德拉3.0

我使用DSE 5.0.5它配備卡桑德拉3.0.11 我試圖使用Spring 1.3.1 XD連接到卡桑德拉 我具有處理數據的處理器模塊和實際攝入數據的接收器。 我想創建流如下 stream create --name ingestion-stream --definition "http --port=9020 |ingestion-transformer| cassandra-3 --con

spring spring-xd spring-data-cassandra 2017-02-17

---

0熱度

1回答

獲取springframework的FatalBeanException

嗨，我實現彈簧XD框架，我已經加入我的彈簧module.xml <?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:int=

spring-integration spring-xd 2017-02-21

---

0熱度

1回答

Spring XD：流和源是入站/出站通道適配器？

Spring的XD中的源組件的設計總是像Spring Integration的入站通道適配器？ 同樣的問題約接收器組件：總是設計像出站通道適配器？ 在文檔here about the sink和這裏about the source我只讀了關於這些適配器，但它並不清楚！

spring-integration spring-xd spring-cloud-dataflow 2017-02-23

---