> On 5. Jul 2022, at 01:48, Alexander Fedulov <alexan...@ververica.com> wrote: > > Hi David, > > I started working on FLIP-238 exactly with the concerns you've mentioned in > mind. It is currently in development, feel free to join the discussion [1]. > If you need something ASAP and are not interested in rate-limiting > functionality, you could drop in this [2] class into your tests suite (this > version is standalone and does not require changes in any other classes). The > usage is as indicated in the FLIP (minus sourceRatePerSecond parameter) [3]. > > [1] https://lists.apache.org/thread/7gjxto1rmkpff4kl54j8nlg5db2rqhkt > [2] > https://github.com/afedulov/flink/blob/FLINK-27919-generator-source/flink-core/src/main/java/org/apache/flink/api/connector/source/lib/DataGeneratorSourceV0.java > [3] > https://cwiki.apache.org/confluence/display/FLINK/FLIP-238%3A+Introduce+FLIP-27-based+Data+Generator+Source#:~:text=%7D-,Usage%3A%C2%A0,-The%20envisioned%20usage > > Best, > Alexander Fedulov
> On Mon, Jul 4, 2022 at 12:51 PM Chesnay Schepler <ches...@apache.org> wrote: > It is indeed not easy to mock sources/sink with the new interfaces. > > There is an effort to make this easier for sources in the future (FLIP-238). > > For the time being I'd stick with the old APIs for mock sources/sinks. > Hi Chesnay and Alexander, thank you both for your answers and pointing me to FLIP-238. I will definitively have a look at your DataGeneratorSource, Alexander; thank you. Then I will only need a sink to go with it. :) But knowing what the state is helps tremendously with our decisions. Thank you again for you help and have a great day. Best David
smime.p7s
Description: S/MIME cryptographic signature
