spring-xd

    0熱度

    1回答

    我上線配置Spring XD。 數據導入導出和加工彈簧XD其上所需要的所有端口打開裏面集羣數據節點紗。 我可以看到端口的Redis,兔,數據庫,我們要運行下一個走集羣。 感謝,

    1熱度

    2回答

    我已經創建了一個自定義的模塊在春季XD其中,「類別中號擊中Oracle數據庫和緩存使用ehcache.Other比目前在XD/lib下我是罐子結果在我的模塊中使用「ehcache-2.9.0.jar和ojdbc6-11.1.0.7.0.jar」。我爲我的自定義模塊創建了UBER jar。尤伯杯罐/ lib目錄既包含了額外的罐子,我added.Module上傳命令的工作效果很好,當我在XD env.

    1熱度

    1回答

    我創建一個春天XD流象下面這樣: stream create foo --definition "jdbc --url=jdbc:mysql://localhost:3306/test --driverClassName=com.mysql.jdbc.Driver --query='select * from employee' |hdfs --inputType=text/plain --rol

    0熱度

    1回答

    我想看到一個工作,我跑的執行狀態作業執行狀態的時候,但在某些隨機點我收到以下錯誤: 2015-10-14T14:41:24-0400 1.2.0.RELEASE ERROR qtp195949131-28 rest.RestControllerAdvice - Caught exception while handling a request org.springframework.http.c

    0熱度

    1回答

    安裝彈簧XD我安裝以下軟件: 的CentOS 6.7 阿帕奇Ambari 2.1.2 我試着通過Ambari安裝彈簧XD,所以我閱讀以下教程: https://github.com/spring-projects/spring-xd-ambari/blob/master/src/docs/asciidoc/InstallingXDwithAmbari.asciidoc 當我嘗試安裝春天XD通過Am

    0熱度

    1回答

    我想使用spring xd從Web服務使用HTTP/1.1協議來獲取text/xml響應。目標是將xml響應轉換爲json並插入到mongodb中。但現在我無法從流中獲得任何迴應。我想這樣做編程,而不是在殼,下面是我的代碼 public static void main(String[] args) { SpringXDTemplate template = null; t

    0熱度

    1回答

    我們有以下要求, 春天XD,我們有工作讓我們假設中的任務名稱爲MyJob 將由另一個進程使用調用Spring xd的其餘服務,讓我們假設進程名稱爲OutsideProcess(非Spring xd進程)。 當有一個文件添加到OutsideJob正在偵聽的位置(讓我們假設FILES_LOC)時,OutsideJob會調用MyJob。 在這種情況下,我們假設MyJob需要5分鐘才能完成作業。 上午10

    0熱度

    1回答

    我想在Spring XD中創建一個以HTTP源開始的流,將流執行的結果作爲響應的主體。 在下面的例子中,我想知道是否有任何東西我可以用在轉換後的大寫字母后面,這樣原始http post的響應正文就是上層的實體。 stream create --name httptest --definition "http | transform --expression=payload.toUpperCase(

    0熱度

    1回答

    我正在使用Spring XD創建流twittersearch,然後連線到我的tweet處理器,然後連接到日誌。 我使用的Java配置類的所有罰款沒有任何問題的話,我想用@ImportResource @Configuration @ImportResource("config/applicationContext.xml") @EnableIntegration public class M

    1熱度

    1回答

    我目前正在研究我的第一個SpringXD流。它應該在MQTT主題上接收消息,在服務上執行HTTP POST並在另一個MQTT主題上發佈此結果。 目前我被困在發佈到不同於最初的MQTT主題。 這是我的流: stream create test --definition "in:mqtt --url='tcp://hivemq:1883' --topics='+/+/+/my/downlink' --