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<Split extends SourceSplit>	An implementation of RateLimiter that completes defined number of futures in-between the external notification events.
class	GuavaRateLimiter<Split extends SourceSplit>	An implementation of RateLimiter based on Guava's RateLimiter.
class	NoOpRateLimiter<Split extends SourceSplit>	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<SplitT>	RateLimiterStrategy.createRateLimiter(int parallelism)	Creates a RateLimiter that limits the rate of records going through.

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

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