Initial PipelineStage

Iterates over rows from a source, passing though a transformation
chain and writing to the appropriate sinks.