Executor 2.0: Per-operator stream assignment policy

Executor 2.0: Per-operator stream assignment policy #1593