spring-xd

    0熱度

    3回答

    我正在使用Spring XD和GemFire XD。我想了解Spring XD的分佈式環境如何工作。我知道spring xd使用redis或rabittmq作爲傳輸。 我很清楚,我已經在一臺機器上安裝了spring xd和rabittmq。我更改了redis.properties文件並添加了主機名。 我是否需要在所有機器上安裝spring xd?如果是這樣,安裝後,如何把這些提出來。 在主控機器,

    1熱度

    1回答

    例如,我想創建一個由模塊爲「myprocessor」: xd> module compose myprocessor --definition "processor1 | processor2 | processor3". 此外,我還希望使處理器1,processor2的數量和processor3是4:2:1在組合模塊中,它們之間的所有通信都在進行中。 我該如何實現它?我可以在創建過程中使用命

    1熱度

    1回答

    我已將環境變量spring.profiles.active設置爲"qa",這是我想要激活的application.yml文件中的配置文件。 但是設置這個環境變量,並在XD-singlenode開始Sprind XD之後,我拋出了以下異常 Exception in thread "main" org.springframework.beans.factory.BeanCreationExceptio

    0熱度

    1回答

    我正在尋找閱讀Redis LIST來閱讀Spring XD失敗的消息,並通過批處理工作流再次處理它們。是否有可用的Redis項目閱讀器?我檢查了批處理的GitHub倉庫,找不到一個倉庫。由於

    5熱度

    1回答

    有沒有一種方法可以啓動一組在啓動spring xd的新實例時定義的流和輕敲? 這種情況是這樣的:我們已經在我們的開發系統上做了一些原型設計,但是現在我們想要構建這個原型並將其發佈給測試團隊。我們希望自動完成大部分後臺工作,用戶只需要擔心流的輸出,而不必擔心流或其定義或部署。 爲了方便起見,我們可以使用任何運行時配置嗎? 更新:我們當前的方法涉及到編寫一個shell腳本來對Spring API進行一

    2熱度

    1回答

    我一直在使用Spring XD一段時間來持續攝取傳感器數據,並且它完美地工作。 我的新要求是「重放」數據部分的能力。在我的特殊情況下,它將從MongoDB中讀取數據(通過一定的查詢),生成一個帶有特定字段的UDP數據包,並在固定的時間間隔內將其發送到SocketAddress。 我正在實施的第一項嘗試是通過彈簧批處理作業。讀者很簡單,因爲它只是查詢MongoDB的數據,但我擔心UDP部分。使用sp

    0熱度

    1回答

    什麼是Spring XD的恢復語義。我已經瀏覽了所有公開的資源,但仍然無法獲得明確的答案。 詳細說明我的問題並保持簡單。 a)當源出現故障時會發生什麼? b)處理器失敗時會發生什麼? c)水槽失效時會發生什麼?

    1熱度

    1回答

    我正試圖使用​​xd-singlenode和xd-shell將Spring XD流存儲到Hortonworks沙箱版本2.0。沒有創建xd目錄,並且沒有流存儲在Hortonworks hadoop hdfs中。 環境: Apple OSX 10.9.3,使用橋接模式網絡在Oracle Virtualbox(Red Hat 64bit)中運行的Hortonworks Sandbox。我在WiFi路由

    7熱度

    2回答

    我在尋找Apache Spark流將適用的情況以及Spring XD流最適合的情況。 這裏有技術上的重疊嗎?有人遇到過兩種情況都在使用嗎?

    -2熱度

    1回答

    在連接的車上發現了這個Spring XD演示 - 認爲這很有趣(https://www.youtube.com/watch?v=qkm2GV57hzY)。 不知道源代碼是否爲OSS,可用於github或某處。