Provide convenience method for setting constant values on sinks.
Change PipelineStage constructor/execute interface.

PipelineStages are now built without needing a Source, and one is
provided when execute is called. This allows source rows to come from
different datasets at runtime.