Hi, Ignite supports simple continuous mapping API[1] for a stream of data. I do not understand why you will not can filtered a data on map job or implement you own interface. But I think, you can got issue with collocation in this approach.
[1]: https://apacheignite.readme.io/docs/continuous-mapping -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/Ignite-Stream-Processing-tp12180p12241.html Sent from the Apache Ignite Users mailing list archive at Nabble.com.
