Stream Processing In A Heterogeneous Environment