On Sun, Sep 18, 2016 at 10:38 PM, Aljoscha Krettek <aljos...@apache.org>
> use UnboundedFlinkSink to wrap a Flink Sink for use in a Beam pipeline.
> The latter would allow you to use, for example, BucketingSink or
> RollingSink from Flink. I'm only mentioning UnboundedFlinkSink for
> completeness, I would not recommend using it since your program will only
> work on the Flink runner.
This seems very useful for all the runners. Would be great to have a way to
use existing sinks in unbounded context.