Curracurrong: a stream processing system for distributed environments