siddhi クエリ言語を使用しようとしていますが、誤用しているようです。
次の streamdef を持つイベントがいくつかあります。
{ 'name':'eu.ima.stat.events', 'version':'1.1.0', 'nickName': 'Flux event Information', 'description': 'Details of Analytics Statistics', 'metaData':[ {name:'HostIP','type':'STRING'} ], 'correlationData':[ {name:'ProcessType','type':'STRING'}, {name:'Flux','type':'STRING'}, {name:'ReferenceId','type':'STRING'} ], 'payloadData':[ {'name':'Timestamp','type':'STRING'}, {'name':'EventCode','type':'STRING'}, {'name':'Type','type':'STRING'}, {'name':'EventInfo','type':'STRING'} ]}
次のようなクエリを使用して、同じプロセス値と同じフラックス値でイベントをフィルタリングしようとしています:
from myEventStream[processus == 'SomeName' and flux == 'someOtherName' ]
insert into someStream
processus, flux, timestamp
これを試すたびに、出力は生成されません。フィルターを外すと
from myEventStream
insert into someStream
processus, flux, timestamp
すべてのイベントが出力に表示されます。
クエリの何が問題になっていますか?