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

fileQueue

@Singleton
@Named(value = "fileQueue")
@Requires(condition = IsFileTransferCondition::class)
fun fileQueue(@Named(value = "numInputPartitions") numInputPartitions: Int): PartitionedQueue<PipelineEvent<StreamKey, DestinationRecordRaw>>

A queue for records with file references for file uploading.