bulk-cdk-toolkit-load-object-storage/io.airbyte.cdk.load.factory.object_storage/ObjectLoaderQueueBeanFactory/recordQueue

recordQueue

@Singleton
@Named(value = "recordQueue")
fun recordQueue(@Named(value = "numInputPartitions") numInputPartitions: Int): PartitionedQueue<PipelineEvent<StreamKey, DestinationRecordRaw>>

A queue for records uploading.