THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||||
---|---|---|---|---|
| ||||
package org.apache.flink.api.common.io.ratelimiting; /** The interface that can be used to throttle execution of methods. */ public interface RateLimiter extends Serializable { /** * Acquire method is a blocking call that is intended to be used in places where it is required * to limit the rate at which results are produced or other functions are called. * * @return The number of milliseconds this call blocked its caller. * @throws InterruptedException The interrupted exception. */ int acquire() throws InterruptedException; } |
...