Package | Description |
---|---|
org.apache.flink.connector.base.sink.writer.strategy |
Modifier and Type | Class and Description |
---|---|
class |
BasicRequestInfo
Dataclass to encapsulate information about starting requests.
|
Modifier and Type | Method and Description |
---|---|
void |
CongestionControlRateLimitingStrategy.registerInFlightRequest(RequestInfo requestInfo) |
void |
RateLimitingStrategy.registerInFlightRequest(RequestInfo requestInfo)
Registers the information of requests being sent (e.g.
|
boolean |
CongestionControlRateLimitingStrategy.shouldBlock(RequestInfo requestInfo) |
boolean |
RateLimitingStrategy.shouldBlock(RequestInfo requestInfo)
Decides whether the next request should be blocked.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.