spring-xd

    0熱度

    1回答

    stream create --name TailTest --definition "tail --name=/Users/name/Documents/SpringXD/PoC/input/Try.txt --outputType=text/plain --lines=1 |file --name=output --dir=/Users/name/Documents/SpringXD/PoC/

    2熱度

    1回答

    我已經設法讓Spring Xd在我從一個JMS代理進入數據的場景中工作。 我可能正面臨一種情況,即可能會從不同來源獲取數據,因此需要我連接到不同的經紀商。 基於我目前的理解,我不太清楚如何做到這一點,因爲存在允許您只安裝一個代理的JMS配置文件。 有沒有解決這個問題的方法?

    0熱度

    1回答

    我們正在使用Spring XD,得到一些JSON數據,需要建立水龍頭,需要通過使用Groovy腳本做的記錄總和.. 還需要一些聚合函數像最小值,最大值通過使用Groovy腳本.. 具有類似於如何做到這一點..

    2熱度

    1回答

    有很多關於如何在java中編寫變換器等但沒有任何關於過濾器的例子(腳本類型過濾器除外,但我想使用java方法)。 我想創建一個自定義的Java過濾器來過濾消息的有效負載從源到接收器。 過濾器的例子都是指一個表達式。 (How)我可以告訴上下文在指定的類中執行java方法作爲表達式嗎?

    1熱度

    2回答

    我創建了一個郵件流用下面的命令------- stream create --name mailstream --definition "mail --host=imap.gmail.com [email protected] --password=my password | file --dir=/tmp/gmailData" --deploy 參考 - http://docs.spring

    0熱度

    1回答

    我試圖讓Spring-XD與Hortonworks Sandbox VM一起工作。 一切都很順利,直到第一,測試流: xd:>stream create --name ticktockhdfs --definition "Time | HDFS" xd:>stream destroy --name ticktockhdfs xd:>hadoop fs ls /xd/ticktockhdfs

    1熱度

    1回答

    我使用的是spring-xd-1.0.0.M6。 我嘗試配置MySQL數據庫作爲彈簧XD 水槽我跟隨 - http://theblasfrompas.blogspot.in/2014/01/springxd-filetail-input-ingestion-jdbc.html 我把我的jdbc.properties文件 - 在 1)spring-xd-1.0.0.M6/xd/modules/sin

    0熱度

    2回答

    我正在嘗試簡單的spring XD應用程序來加載HDFS中的日誌事件。我已經使用spring-ampq/rabbit log4j appender(org.springframework.amqp.rabbit.log4j.AmqpAppender類)配置了目標應用程序,將日誌消息泵送到預配置的交換機。我設置以下流拉從那些消息並將它們推到HDFS,其中兩個soruce和宿模塊是現成的,貨架XD模塊

    0熱度

    1回答

    我無法從文檔中獲取信息。任何人都可以告訴我Spring-XD如何執行作業?它是否將作業分配給某個容器,並且該作業是僅在其部署到的容器上執行的,還是將每個作業執行分配給另一個容器?我能以某種方式控制某個工作可以並行執行(使用不同的參數),而其他人則不可以? 謝謝! 彼得

    4熱度

    1回答

    是否有任何使用純java配置(無xml)的spring xd的示例。 我創建了一個簡單的tasklet,jarre相同(whojob.jar)並將其放入lib文件夾。 xml配置如下。我把它放在一個名爲whojob的文件中,該文件位於modules/job文件夾中,並且與我的whojob.jar一起震動。 當我嘗試創建一個作業時: - (:> job create --name mywhojob