On Sun, Sep 18, 2016 at 10:38 PM, Aljoscha Krettek <[email protected]> wrote:
> 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.
