I just copied the file from the spring-xd-analytics module.

If the abstractions are set - I wanted to describe them here.