Flink算子如何限流

目录

使用方法

调用类图

内部源码 

GuavaFlinkConnectorRateLimiter

RateLimiter

---

使用方法

重写AbstractRichFunction中的open()方法，在处理数据前调用limiter.acquire(1);

调用limiter.open(getRuntimeContext())的源码，实际内部是RateLimiter,根据并行度算出subTask中RateLimiter的permitsPer