spring-xd

2熱度

1回答

可以說，我想這個確定指標 file | serviceActivator1 | transform | serviceActivator2 創建流所以我在這個定義中的兩個自定義模塊。我的理解是，Spring xd將創建每個組件/模塊的子上下文並將其部署到一個容器中。如何跨serviceActivator1和serviceActivator2共享單個bean。基本上這個bean應該在父上下文中定義

2熱度

1回答

Spring XD作爲Rest端點

我們可以整合Spring XD和Spring MVC，以便我們可以接收/處理髮送到REST端點的數據嗎？我們在Spring MVC應用程序中收集了大量的數據，並且想知道我們是否可以使用Spring XD。

0熱度

1回答

Spring XD：是否可以在單個模塊中有多個作業

我使用Spring XD執行批處理任務，該任務本身分爲兩個獨立的作業，它們位於同一個（job：）模塊中。現在我對Spring XD/Batch很陌生，所以我只對框架有一個相當基本的理解。我想知道是否有辦法分別處理每項工作？我知道我可以部署一個工作給它模塊名稱，但是我還沒有找到一種方法來指定我想部署哪個工作。每個模塊應該只有一個作業嗎？如果不是，我該如何分別討論/部署這些工作？請讓我知道如果問

0熱度

1回答

Spring XD是否僅有一個Container容器？

在Distributed Mode中運行Spring XD時，將會有許多JVM運行XD容器。是否存在XD發行版的「瘦身」版本，其中只包含運行容器所需的bin/libs？

2熱度

1回答

如何使用Spring XD將tweets放入avro文件並將其保存在HDFS中？

如何使用Spring XD將tweets放入avro文件並將其保存在HDFS中？該實況只告訴我要做到以下幾點： xd:>stream create --name mydataset --definition "time | hdfs-dataset --batchSize=20" --deploy 這正常來源爲「時間」，但如果我要存儲的鳴叫作爲Avro公司只把生的JSON字符串在Avro的文件

1熱度

1回答

無法運行測試spring-xd-samples（rss-feed-source）

前言：我已經嘗試了好幾天在我自己解決這個問題之前打擾你們任何一個好人。提前道歉。我的問題：測試掛起我的自定義源模塊以及spring-xd-samples項目rss-feed-source。我在Java 1.7 OSX 10.9.5上運行spring-xd 1.1.1.RELEASE，並在終端以及Spring Tool Suite中看到與mvn相同的結果。值得一提的是，我沒有運行spring的x

1熱度

2回答

使用spring-xd查找

我正在尋找使用spring-xd執行查找操作的方法。我的問題陳述是這樣的，我進來的JSON事件流，我想有事件的值查到的在HDFS或直接從RDBMS在我的文件針對的閾值。請建議一種方法來執行此操作。感謝您提前。

2熱度

1回答

Spring XD：如何決定何時使用流或批處理作業？

我們目前正在開發一個從文件系統/ ftp/http讀取文件並將這些文件上傳到mongodb的應用程序。之後，我們要分析這些文件並在mongodb中寫入分析的文檔。這個過程的要求：實時上傳和分析。故障處理和重新啓動過程。重新分析文件的可能性。在Spring XD中如何正確地組織這個過程？在什麼情況下，我們應該使用流或批處理作業？如果任何人都可以說出使用流代替批處理作業的最佳實踐，反之亦然

1熱度

2回答

spring-xd kafka水槽（文件）寫ascii代碼

我正在用spring-xd測試apache-kafka。我按照這個例子。 http://spring.io/blog/2015/04/15/using-apache-kafka-for-integration-and-data-processing-pipelines-with-spring 它工作正常，我正在接觸spring-xd。 xd> stream create kafka-source

1熱度

1回答

Spring XD - 過濾器中SpEL表達式中的instanceof

我想在過濾器中的SpEL表達式中使用instanceof運算符作爲流。我正在嘗試以下操作： stream create myStream --definition "tap:job:jobName > filter --expression='payload instanceof T(com.package.name.event.SomeEvent)' | log --deploy 我將自己的