GuavaRateLimiter (Flink : Core 1.20.2-cp1 API)

java.lang.Object
- org.apache.flink.api.connector.source.util.ratelimit.GuavaRateLimiter

All Implemented Interfaces:

RateLimiter
```
@Internal
public class GuavaRateLimiter
extends Object
implements RateLimiter
```
An implementation of RateLimiter based on Guava's RateLimiter.

Constructor Summary

Constructors
Constructor Description

GuavaRateLimiter(double maxPerSecond)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	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
  - GuavaRateLimiter
```
public GuavaRateLimiter(double maxPerSecond)
```
- 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