On Tue, Feb 28, 2017 at 11:38 AM, Aljoscha Krettek <aljos...@apache.org> wrote: > I see the ProcessFunction as a bit of the generalised future of FlatMap, so > to me it makes sense to only allow side outputs on the ProcessFunction but > I'm open for anything. If we decide for this I'm happy with an additional > method on Collector.
I think it's best to restrict this to ProcessFunction after all (given that we allow it for non-keyed streams, etc.). ;-)
