Re: Access to collector in the process function

Hi, Oscar The collector object is created in [1] open method, so we can't get it in ProcessFunciton open method. One possible way is you change the source code, place it in ProcessFunction#Context. [1] https://github.com/apache/flink/blob/aa8d93ea239f5be79066b7e5caad08d966c86ab2/flink-streaming-j

Access to collector in the process function

Hi! We would like to use hexagonal architecture in our design and treat the collector as an output port when sending events from the use case. For that, we would like to call an interface from the use case that effectively sends the event ultimately via out.collect The problem is that for instant