Hello, Question 1 I don’t see any reference material showing how to write compressed (gzip) files with StreamingFileSink. Can someone point me in the right direction?
Question 2 We currently have a use case for a “StreamingFileProcessFunction”. Basically we need an output for the StreamingFileSink that will be used by a downstream processor. What would be the best way to implement this feature? Best, Song
