Remove unused flush method from MessageSink interface
Add field for partition id
Don't hang forever when Samza is weird
Pull most of the logic into MessageSinks
More removals from CoastTask

Now all the complexity is isolated to the MessageSink.Factory, hopefully
it should be easier to provide multiple implementations.
Handle groupBy

Big mess still, but it runs!
samza notes