Implement a switch function

[jecsand838]

In order to support conditional branching in a pipeline, we need to implement a switch function which inputs a DataStream, a RouteFunc and routes to two or more output DataStream based on the results of the RouteFunc.