Add the ability to pin a stage to a worker

[jtfmumm]

Sometimes users might want to be able to control where a stage of the pipeline is executed. For example, if they are using a local_key_by to create local aggregations and want the final aggregation to take place on a particular machine.