Added support for splitting FlowSources by distributing.

Some minor refactoring and convenience additions.
Extended the API and implemented distributed word count (somewhat indeterministic right now, needs debugging)