bulk-cdk-toolkit-load-db/io.airbyte.cdk.load.pipeline.db/InsertLoaderRequestQueueFactory

InsertLoaderRequestQueueFactory

@Factory
@Requires(bean = InsertLoader::class)
class InsertLoaderRequestQueueFactory<Q : InsertLoaderRequest>

Constructors

Link copied to clipboard
constructor()

Functions

Link copied to clipboard
@Singleton
@Named(value = "insertLoaderClampedRequestSizeBytes")
@Requires(bean = InsertLoader::class)
fun insertLoaderClampedPartSizeBytes(@Named(value = "insertLoaderRequestQueue") queue: ResourceReservingPartitionedQueue<*>): Long
Link copied to clipboard
@Singleton
@Named(value = "insertLoaderRequestQueue")
@Requires(bean = InsertLoader::class)
fun <Q : InsertLoaderRequest> insertLoaderRequestQueue(insertLoader: InsertLoader<Q>, @Named(value = "globalMemoryManager") reservationManager: ReservationManager): ResourceReservingPartitionedQueue<PipelineEvent<StreamKey, InsertLoaderRequestBuilderAccumulator.Result<Q>>>