cep

2熱

2答えて

私はKieワークベンチ6.3.0を使用してルールを作成しています。ストリームモードでルールを実行しようとしています。私はkie-wbでプロジェクトを作成し、kie-baseを作成しました。このためにkie server runtimeを使用しています。 <kmodule xmlns="http://jboss.org/kie/6.0.0/kmodule" xmlns:xsi="http://w

0熱

2答えて

CEPウィンドウをクリアする方法

同じイベント（同じタイトルを持つ）をinOrgストリームに2回入力することをブロックしたかったのです。だから私は "最初のユニークな"ウィンドウを使いました。しかし、ある時点では、これはメモリ不足エラーを引き起こします。私は1000以上のイベントが含まれている場合、最初のユニークなウィンドウをきれいにしたい。これどうやってするの？これは実行計画です。 @Plan:name('ExecutionP

0熱

1答えて

WSO2 CEP - 複数の実行プランのための単一のイベントテーブル

私はここ数日間WSO2 CEPを調査しています。複数の実行計画で単一のルックアップテーブルを使用できるシナリオを検討しています。私が知る限り、すべてのデータを格納する唯一の方法はイベントテーブルです。私の質問は以下のとおりです。私は一度イベントテーブルをロードする（1つの実行計画によるものであってもよい）、およびその他の実行計画とそのテーブルを共有することはできますか？ Q1の回答がNOの場

0熱

1答えて

siddhiで時間管理

ホワイトリストを2分保存する必要がありますが、新しいストリームが到着したときに私のホワイトリストを使ってクエリを実行する必要があります。私は次のコードで2つのストリームを使用しています： 2分ごとに更新されるWHITELISTを請求する必要があります。 define trigger periodicalTriggerStream at every 2 min; from DSB_TEMPORA

0熱

1答えて

のApacheのIgnite CEP実装

、のIgniteなど私はのIgniteにあったとき、私はのIgniteの照会APIのことを見ました大規模なデータを実行するのに十分な資格はありません。理由は、多くのデータをキャッシュに格納できないことです（不十分なメモリサイズ：2 TBが必要です）。私はライトスルーとリードスルーを見てきましたが、データペイロード（キーではありません）は述語（ex SQLPredicateの場合）で照会できません

0熱

1答えて

WSO2 CEPでデータベース接続をファイルに設定しますか？

ファイルシステム経由で既存のデータベース接続を設定する方法はありますか？Webアプリケーション内では設定できませんか？私は現在、いくつかのイベントを保存するためにOracle DBへのrdbms接続を使用しています。実装を別のシステムに移すので、データベース情報（URL、ユーザ名&のパスワード）を変更する必要があります。データベースは、master-datasources XMLファイルには表

0熱

1答えて

古いイベントの格納はどのようにesperのパフォーマンスに影響しますか？

古いイベントの格納はどのようにesperのパフォーマンスに影響しますか？たとえば、10個の古いイベントを保存する場合のパフォーマンスへの影響と、100個の古いイベントを保存する場合のパフォーマンスの変化の仕方何か変わるでしょうか？私はesperでのメモリ使用量を知りたい。古いイベントはどこに保存されますか？

0熱

1答えて

イベントの単純なシーケンス

タイプA、B、CまたはDのイベントが放出されていると仮定します。私はタイプAのイベントの後にタイプBのイベントが続くたびに検出したいと思います。つまり、EsperのEPLが->演算子を提供するシーケンスを検出したいと思います。 Bが検出されるたびに、私はそれは私がEPLの構文で遊んでてきた最新のA. と一致することにしたい。しかし、私が上記のことは私がしたいことは、以下で、曖昧です select

0熱

1答えて

Siddhi CQEngineはフィルタセクション内で使用されます

受信イベントにuserIdプロパティが含まれています。私はCQEngineからuserIdに従ってパラメータ値を読むことができるようにしたいと思います。これをFunctionExecutorの拡張として実装し、それを次のように使用する必要があります。 define stream cseEventStream (userId string, symbol string, price long, vo

1熱

1答えて

Apache Flink + CEP - 同じイベントを検出する

同じプロパティを共有するイベントを検出したいと思います。私は、単純なケースのクラスがあるとします。 Record("A", 1) Record("B", 2) Record("A", 3) Record("C", 4) その後、私は二重の「A」レコードを検出したいと思います： case class Record(name: String, value: Int) は、以下の流れがある