Uses of Interface
org.apache.flink.connector.base.sink.writer.RequestBuffer

Packages that use RequestBuffer

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

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

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

Modifier and Type	Class	Description
class	DequeRequestBuffer<RequestEntryT extends Serializable>	Default wrapper implementation that uses an ArrayDeque as the underlying data structure.

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

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.

Constructors in org.apache.flink.connector.base.sink.writer with parameters of type RequestBuffer

Constructor	Description
AsyncSinkWriter(ElementConverter<InputT,RequestEntryT> elementConverter, org.apache.flink.api.connector.sink2.WriterInitContext context, AsyncSinkWriterConfiguration configuration, Collection<BufferedRequestState<RequestEntryT>> states, BatchCreator<RequestEntryT> batchCreator, RequestBuffer<RequestEntryT> bufferedRequestEntries)
BufferedRequestState(RequestBuffer<RequestEntryT> requestBuffer)