2017-01-16 4 views
0

スプリッタとアグリゲータの作成方法については、Stream Cloud Data Flow(Stream XDではなく)に固有のいくつかの例を指し示すことができますか?Spring Cloudデータフローアグリゲータの例

特に、メッセージの非自明な分割と結合。複雑なストリームの例はありません。分割後にメッセージを集約しているストリームを定義する方法、生成されたメッセージのルーターと別の処理についてはどうしたら後で集計するのですか?

PS:長い質問のため申し訳ありませんが、必要に応じて明確にします。感謝! ありがとう!

答えて

0

splitterhereのために利用可能なボックスアプリがあります。アグリゲータはまだOOTBアプリに追加されており、追跡中ですhere。あなたはthisに基づいてアプリを書くことができ、あなたの貢献は大歓迎です!

+0

ありがとうございます!私は提供されたリンクを読みましたが、誰かがこの質問を見つけた場合に役立つものがいくつかあります:[リンク] https://github.com/spring-cloud/spring-cloud-stream-app-startersそれには他の初心者が含まれています。私は非常にシンプルな@Agregatorアノテーションを持つメソッド、パラメータとしてMessageのリストと単一のMessageの結果を返すメソッドに基づいて、ジェネレータを終了しました...まだ複雑なストリームの例の問題に答えることはできません。 – ka2

+0

私はこれを参考にして答えとしてマークしますが、より複雑な例を公開するのはいいと思います... – ka2

関連する問題