2017-12-19 7 views
0

私はイベントのデータストリームとパターンの別のデータストリームを持っています。パターンは実行時にユーザーによって提供され、カフカのトピックを介して来る必要があります。 Flink-CEPを使用して、イベントストリームにパターンのそれぞれを適用する必要があります。 パターンがあらかじめわからないときに、DataStreamからPatternStreamを取得する方法はありますか?Apache Flink:ソースから別のデータストリームにパターンを適用する方法は?

答えて

1

現時点では不可能です。 FlinkCEPは、静的に適用された1つのパターンのみを処理できます。そのためのJIRAチケットはhttps://issues.apache.org/jira/browse/FLINK-7129ですが、この機能についてETAに伝えることはできません。

+0

タイムウィンドウを使用してこのロジックを複製することはできますか? – wittyameta

関連する問題