Online state migration in modern stream processing engines