Hi! The main API for streaming and CEP is IgniteDataStreamer, which can be used to stream events into Ignite cache: http://apacheignite.readme.io/v1.0/docs/streaming--cep
Ignite provides sliding window capabilities which are configured as cache eviction policies (http://apacheignite.readme.io/v1.0/docs/sliding-windows) and a full set of indexing and quering capabilities to query over streamed data (http://apacheignite.readme.io/v1.0/docs/cache-queries) It also looks like continuous queries can be useful in your case. They allow to register listener for events filtered by some condition: http://apacheignite.readme.io/v1.0/docs/continuous-queries -- Val ----- -- Val -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/CEP-How-to-Respond-to-a-particular-Input-Stream-ie-Listener-tp298p300.html Sent from the Apache Ignite Users mailing list archive at Nabble.com.
