Package org.apache.flink.api.connector.source.util.ratelimit

Interface Summary

Interface	Description
RateLimiter	The interface to rate limit execution of methods.
RateLimiterStrategy	A factory for RateLimiters which apply rate-limiting to a source sub-task.

Class Summary

Class	Description
GatedRateLimiter	An implementation of RateLimiter that completes defined number of futures in-between the external notification events.
GuavaRateLimiter	An implementation of RateLimiter based on Guava's RateLimiter.
NoOpRateLimiter	A convenience implementation of RateLimiter that does not throttle requests.
RateLimitedSourceReader<E,SplitT extends SourceSplit>	Wraps the actual SourceReader and rate limits its data emission.