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

Packages that use BatchCreator

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

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

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

Modifier and Type	Class	Description
class	SimpleBatchCreator<RequestEntryT extends Serializable>	A simple implementation of BatchCreator that forms a batch by taking up to requestInfo.getBatchSize() entries from the head of the buffer, so long as the cumulative size in bytes does not exceed the configured maximum.

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

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)