cep

0熱

1答えて

FiWARE CEPでLiveDemoプロジェクトのインスタンスを起動しているときに出力アダプタを初期化できませんでした

FiWARE CEPでLiveDemoプロジェクトのインスタンスを起動中にエラーが発生しました。出力アダプターの初期化に失敗します。 INFO [Thread-27] com.ibm.hrl.proton.server.adapter.OutputServer.run Proton output server started, listening on output port: 3302 WAR

0熱

1答えて

エスパーCEPとレストAPI

@POST @Path("/minPrice") @Consumes(MediaType.APPLICATION_JSON) public String minPrice() { String userQuery = "select min(price) from MyEventClass"; String userFileName = "MyInputFIle.csv"

0熱

1答えて

warnings.print（）（最初の最後のイベント）逆の順序でイベントを出力しますが、ApacheのFLINK CEPで最初のイベントをexceptsで

私はパターンの下に使用してFLINKに> 10あるすべての一時イベントをフィルタしようとしています、 Pattern<MonitoringEvent, ?> warningPattern = Pattern.<MonitoringEvent>begin("first") .subtype(TemperatureEvent.class) .where(new Filt

0熱

1答えて

siddhiスナップショットはネットワーク環境で動作するように設計されていますか？

siddhiスナップショットは、ネットワーク環境で動作するように設計されていますか？私は何かをすることはできますか？ネットワーク executionPlanRuntime.restore(revision);

2熱

2答えて

エスパパターンタイマー：interval（）が動作しません

私はこの基本的なPOCコードを持っています。私はイベントが公開されているのを見ることができますが、リスナーには何の警告も出ません。以下のコードでは、pattern1またはpattern2のいずれのステートメントにも警告がありません。設定のsetInternalTimerEnabledはデフォルトではTrueですが、コードでTrueを設定しようとしましたが、同じ問題です。何か不足していますか？

1熱

1答えて

Apache flink CEPライブラリの問題（クラスタ）

Eclipseでかなりうまく動作しているアプリがあります。クラスタにデプロイするときには、これで非常に迅速に失敗します。 java.lang.RuntimeException：メイン（String []型）クラスorg.ice.drmcl.Applicationから方法を検索できませんでした： ORG/apache/flink/cep/pattern/conditions/IterativeCo

0熱

1答えて

SmartRESTで累積リアルタイム通知を受信する方法は？

累積REST APIを使用しています。定期的なリアルタイム通知が機能します（例：私たちは/ alarms/*を購読して接続/ポーリングループを開始し、アラームを生成すると期待されるJSONを受信します。特定のモジュールやステートメントはインストールされていません。しかし、我々はSmartRESTと同じことをしようとすると、我々はすぐにアラームが作成されると、このエラーが表示されます。 40,,/

0熱

2答えて

lastUnique（）の反対

EsperとEPLには一般的に2つのユースケースがありますが、基本的にはどちらかといえます。最初に、firstunique(*parameters*).win:time(*time*)を使用して、タイムウィンドウ内のすべてのユニークなイベントを捕捉する必要があります。私がする必要があるのは、正反対です。基本的には、そのウィンドウに到着し、そのステートメントによってスローされないすべてのイベントを

0熱

2答えて

ドメインデータ/参照データの実装ですか？

かなり簡単な質問ですが、私はドキュメントを介してそれを行う方法を見つけることができませんでした。私はすべてのイベントを比較することができるリファレンスデータのコアセットに興味があります。単純な例では、nodeIDについて話しているセグメンテーションコンテキストがありますが、それはフォークパーティションに入っているノードID の異なる値です（後で使用することができます（集約など））。事前移入または

1熱

1答えて

Apache用の動的ストリームSQL Flink CEP

CEP用Flinkで消費されるストリームSQLをKafkaに入れたいと思います。これは良い方法ですか？私は動的パターン定義がFlinkでは許可されていないことを知っており、無制限のイベントストリームで変更できるルールを適用する必要があります。例を挙げてください。ユーザーがデバイスのルールを定義するためのUIがあります。 AWS IoTハブのようなサービスをシャドウイングして物理デバイスの状態