System Support For Stream Processing In Collaborative Cloud-Edge Environment