Uses of Interface
org.apache.flink.api.connector.source.util.ratelimit.RateLimiter

Packages that use RateLimiter

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

Uses of RateLimiter in org.apache.flink.api.connector.source.util.ratelimit

Classes in org.apache.flink.api.connector.source.util.ratelimit that implement RateLimiter

Modifier and Type	Class	Description
class	GatedRateLimiter	An implementation of RateLimiter that completes defined number of futures in-between the external notification events.
class	GuavaRateLimiter	An implementation of RateLimiter based on Guava's RateLimiter.
class	NoOpRateLimiter	A convenience implementation of RateLimiter that does not throttle requests.

Methods in org.apache.flink.api.connector.source.util.ratelimit that return RateLimiter

Modifier and Type	Method	Description
RateLimiter	RateLimiterStrategy.createRateLimiter(int parallelism)	Creates a RateLimiter that lets records through with rate proportional to the parallelism.

Constructors in org.apache.flink.api.connector.source.util.ratelimit with parameters of type RateLimiter

Constructor	Description
RateLimitedSourceReader(SourceReader<E,SplitT> sourceReader, RateLimiter rateLimiter)	Instantiates a new rate-limited source reader.