cep

1熱

2答えて

どのオープンソースのCEP shoudを分散処理とパイプライン処理に使用するか選択します。 siddhi、Flink、Esper？

siddhiクエリー言語を使用しているため、siddhi cepには嫌われていますが、分散処理には嵐が使用され、WSO2はアプリケーションを作成して配備するためのWebインターフェイス/ダッシュボードを提供します。私はいくつかの機能を強化/使用するための独立性が低くなると思う。しかし、Flinkは良い選択だと思われますが、単純なロジックでも実装するには多くのコードが必要です。は、これらのより良

1熱

1答えて

FIWARE Cepheusの一般設定

私はCepheusを使用して、ユーザーがOrionエンティティ間の関係を作成できるようにする予定です。設定ファイルが1つしかないという問題があります。したがって、同じテナント内で複数のCEPを作成することが難しくなります。たとえば、床の平均温度を作成し、シャッターを閉じたいとします（例http://fiware-cepheus.readthedocs.io/en/latest/examples

1熱

1答えて

エラーケフェウス座ブローカー転送しないアップデート

私は私のユースケースのためケフェウス座GEを使用して、私は、マルチテナントモードでそれを有効にし、それに私のconfig.jsonファイルをアップロードし、しかし、私は順番にケフェウス座ブローカーへの更新を送信するために開始それをCEPに転送するには、Cepheusブローカーはアップデートを受け取るだけですが、config.jsonに設定されているサービスとサービスパスを認識できないため、Ceph

0熱

1答えて

時間と長さを持つEsperウィンドウからの最後のイベント

私はtime_length_batchから最後のイベントを取得しようとしていますが、これを行う方法は紛失WRTです。たとえば、在庫イベントがあり、利用可能な各製品から最新のアップデートを取得したいと考えています。次のクエリはほとんど必要とされているものを提供しています。私は、最後の分または2つのイベント内のすべてのイベントを取得し、ウィンドウ内のことを除いて SELECT product, in

0熱

1答えて

Esper - クエリ結果の配列表現

私はCallPOPDWHイベントがあるとします。イベントには4つの列があります。タイプ列、名前列、検出タイムスタンプ列、および属性列を含む。エスパーは、次の3つのタプルを生成します。 [Event, CallPOPDWH, 1456938481000, {call_start_date=7355448481000, calling_number=+3859121JMOYL, call_direct

0熱

1答えて

Flink CEPのシーケンス一致のセマンティクス

Apache JIRAに問題があります：https://issues.apache.org/jira/browse/FLINK-3703。 after first（つまり、現在の動作です）今後の試合のために、すべてのイベントを保ち続ける - from first：それは、一致シーケンスが発見されたと行動の3種類があります後にマッチングアルゴリズムを継続すべき場所を定義することができます - aft

1熱

1答えて

cumulocityでリアルタイムモジュールを削除するには？

既存のモジュールを削除するには、/cep/module/<<moduleId>>に対してDELETE要求を行うと文書（http://cumulocity.com/guides/reference/real-time-statements/）に記載されています。しかし、これは、 "要求メソッド 'DELETE'がサポートされていないという理由で、応答ステータス500になります。 1つのモジュールを削

1熱

2答えて

Apache Flink - x分間のデータがない場合にイベントを送信する

FlinkのDataStream APIを使用して、ある時間ストリームからデータを受信しなかった場合にイベントを送信する演算子を実装するにはどうすればよいですか？

0熱

1答えて

エスパーチェーンに続いてパターンがn回繰り返されますか？

続きのパターンをn回連鎖リピートすることはできますか？私は、例えば、以下のパターンを記述する場合 every a=A -> b=B(b.price < a.price) -> c=C(c.price < b.price) -> d=D(d.price < c.price) -> e=E(e.price < d.price) -> f=F(f.price < e.price) -> g=

0熱

2答えて

Apache Flinkパターン条件リストあり

私はパターンを書きました。私は条件（jsonからgettinのルール）のリストを持っています.Data（json）は、フォームのカフカサーバーに来ています。このリストでデータをフィルタリングしたいのですが。しかし、それは動作していません。どうやってやるの？私はキーストリームとアラームについてはわかりません。このような仕事をすることはできますか？メインプログラム： package cep_kaf