Efficient Distributed Processing Over Micro-batched Data Streams