2016-06-01 9 views
0

実装が可能ですか(dslクエリーを書き込みますか)?春xd。ソース待機シンクの完了

sourcesink処理が完了していない間に待機する必要があります。

sink - 完了 - >sourceが開始します。

例:いくつかの情報をDBへの書き込み

First streamjdbc sink

Second streamは、すべての情報はDB(first stream)に保存されている場合にのみ、何かをしなければなりません。

私はこの瞬間のための唯一の解決策を持っている -

おかげで(内部JDBC-シンク付き)カスタムソースを記述します。

答えて

0

これはSpringXDの問題ではないと思いますが、これはむしろalgorithmの問題です。

真実として、のlockを使用してloading processのステータスを示すことができます。作業が完了していない場合はsource moduleを待機するように設定します。

希望すると、これが役に立ちます。

関連する問題