NoOpRateLimiter (Flink : Core 2.2.0-cp2 API)

java.lang.Object
- org.apache.flink.api.connector.source.util.ratelimit.NoOpRateLimiter<Split>

All Implemented Interfaces:

RateLimiter<Split>
```
@Internal
public class NoOpRateLimiter<Split extends SourceSplit>
extends Object
implements RateLimiter<Split>
```
A convenience implementation of RateLimiter that does not throttle requests.

Constructor Summary

Constructors
Constructor Description

NoOpRateLimiter()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`CompletionStage<Void>`	`acquire(int numberOfEvents)`	Returns a future that is completed once other events 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
acquire, notifyAddingSplit, notifyCheckpointComplete

- Constructor Detail
  - NoOpRateLimiter
```
public NoOpRateLimiter()
```
- Method Detail
  - acquire
```
public CompletionStage<Void> acquire(int numberOfEvents)
```
    Description copied from interface: RateLimiter
    
    Returns a future that is completed once other events 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<Split extends SourceSplit>
    
    Parameters:
    
    numberOfEvents - The number of events.