Hi everyone, I would like to open a discussion on FLIP-238: Introduce FLIP-27-based Data Generator Source [1]. During the discussion about deprecating the SourceFunction API [2] it became evident that an easy-to-use FLIP-27-compatible data generator source is needed so that the current SourceFunction-based data generator implementations could be phased out for both Flink demo/PoC applications and for the internal Flink tests. This FLIP proposes to introduce a generic DataGeneratorSource capable of producing events of an arbitrary type based on a user-supplied MapFunction.
Looking forward to your feedback. [1] https://cwiki.apache.org/confluence/x/9Av1D [2] https://lists.apache.org/thread/d6cwqw9b3105wcpdkwq7rr4s7x4ywqr9 Best, Alexander Fedulov