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

Packages that use RateLimiterStrategy

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

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

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

Modifier and Type	Method	Description
static RateLimiterStrategy	RateLimiterStrategy.noOp()	Creates a convenience RateLimiterStrategy that is not limiting the records rate.
static RateLimiterStrategy	RateLimiterStrategy.perCheckpoint(int recordsPerCheckpoint)	Creates a RateLimiterStrategy that is limiting the number of records per checkpoint.
static RateLimiterStrategy	RateLimiterStrategy.perSecond(double recordsPerSecond)	Creates a RateLimiterStrategy that is limiting the number of records per second.