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

Class NoOpRateLimiter

java.lang.Object

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

All Implemented Interfaces:

RateLimiter

@Internal
public class NoOpRateLimiter
extends Object
implements RateLimiter

A convenience implementation of RateLimiter that does not throttle requests.

Constructor Summary

Constructors

Constructor and Description
NoOpRateLimiter()

Method Summary

Modifier and Type	Method and Description
CompletionStage<Void>	acquire() Returns a future that is completed once another event would not exceed the rate limit.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.api.connector.source.util.ratelimit.RateLimiter

notifyCheckpointComplete

Constructor Detail

NoOpRateLimiter

public NoOpRateLimiter()

Method Detail

acquire

public CompletionStage<Void> acquire()

Description copied from interface: RateLimiter

Returns a future that is completed once another event would not exceed the rate limit. For correct functioning, the next invocation of this method should only happen after the previously returned future has been completed.

Specified by:

acquire in interface RateLimiter