0
受信イベントにuserIdプロパティが含まれています。私はCQEngineからuserIdに従ってパラメータ値を読むことができるようにしたいと思います。これをFunctionExecutorの拡張として実装し、それを次のように使用する必要があります。Siddhi CQEngineはフィルタセクション内で使用されます
define stream cseEventStream (userId string, symbol string, price long, volume long);
@info(name = 'query1')
from cseEventStream [price < custom:cache(userId)]
select *
insert into Output
またはそれを行う方法がいくつかあります。問題は、CQEngineを初めて使用する前にデータで初期化する必要があることです。おそらくFunctionExecutorの "start"メソッドがこの目的のために使用できますか?
こんにちは。ご回答いただきありがとうございます。その間、私はそれを実装することができたし、それは動作します。しかし、FunctionExecutorエクステンションにSpringフレームワークBeanを注入する方法はありますか?私の心に来る唯一の方法は、サービスロケータです。あなたはそれをどうやって他のアイデアを持っていますか?ありがとうございました。 – yshadow