Uses of Interface
org.apache.flink.connector.base.sink.writer.strategy.RequestInfo

Packages that use RequestInfo

Package	Description
org.apache.flink.connector.base.sink.writer
org.apache.flink.connector.base.sink.writer.strategy

Uses of RequestInfo in org.apache.flink.connector.base.sink.writer

Methods in org.apache.flink.connector.base.sink.writer with parameters of type RequestInfo

Modifier and Type	Method	Description
Batch<RequestEntryT>	BatchCreator.createNextBatch(RequestInfo requestInfo, RequestBuffer<RequestEntryT> bufferedRequestEntries)	Creates the next batch of request entries based on the provided RequestInfo and the currently buffered entries.
Batch<RequestEntryT>	SimpleBatchCreator.createNextBatch(RequestInfo requestInfo, RequestBuffer<RequestEntryT> bufferedRequestEntries)	Creates the next batch of request entries based on the provided requestInfo and the currently buffered entries.

Uses of RequestInfo in org.apache.flink.connector.base.sink.writer.strategy

Classes in org.apache.flink.connector.base.sink.writer.strategy that implement RequestInfo

Modifier and Type	Class	Description
class	BasicRequestInfo	Dataclass to encapsulate information about starting requests.

Methods in org.apache.flink.connector.base.sink.writer.strategy with parameters of type RequestInfo

Modifier and Type	Method	Description
void	CongestionControlRateLimitingStrategy.registerInFlightRequest(RequestInfo requestInfo)
void	RateLimitingStrategy.registerInFlightRequest(RequestInfo requestInfo)	Registers the information of requests being sent (e.g. to track the current inFlightMessages / requests).
boolean	CongestionControlRateLimitingStrategy.shouldBlock(RequestInfo requestInfo)
boolean	RateLimitingStrategy.shouldBlock(RequestInfo requestInfo)	Decides whether the next request should be blocked.