TM-Stream is an Event Stream Processing extention to the DSTM2.1 Framework.
We use STM for speculative processing of events in parallel and delay the commit of the associated transaction until we have successfully processed preceding events. Our TM-Stream system can handle ordered as well as unordered incoming events, within a reasonable processing time (> 100μsec).
We further support distributed speculation by allowing events of not yet committed transactions to be processed speculatively by the next components.
- H. Sturzrehm, P. Felber, and C. Fetzer.
TM-STREAM: an STM Framework for Distributed Event Stream Processing.
In Proceedings of the 11th International Workshop on Java and Components for Parallelism, Distribution and Concurrency, Rome, Italy, May 2009.