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

insertLoaderClampedPartSizeBytes

@Singleton
@Named(value = "insertLoaderClampedRequestSizeBytes")
@Requires(bean = InsertLoader::class)
fun insertLoaderClampedPartSizeBytes(@Named(value = "insertLoaderRequestQueue") queue: ResourceReservingPartitionedQueue<*>): Long