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

Interface Summary

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

Class Summary

Class	Description
GatedRateLimiter<Split extends SourceSplit>	An implementation of RateLimiter that completes defined number of futures in-between the external notification events.
GuavaRateLimiter<Split extends SourceSplit>	An implementation of RateLimiter based on Guava's RateLimiter.
NoOpRateLimiter<Split extends SourceSplit>	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.