How to implement new streaming analytics building blocks?

This might be good starting point: