bulk-cdk-toolkit-load-object-storage/io.airbyte.cdk.load.factory.object_storage/ObjectLoaderStepBeanFactory/oneShotObjectLoaderStep

oneShotObjectLoaderStep

@Named(value = "oneShotObjectLoaderStep")
@Singleton
fun <O : OutputStream, K : WithStream, T : RemoteObject<*>> oneShotObjectLoaderStep(objectLoaderOneShotUploader: ObjectLoaderOneShotUploader<O, T>, @Named(value = "numInputPartitions") numInputPartitions: Int, @Named(value = "objectLoaderCompletedUploadQueue") completedUploadQueue: PartitionedQueue<PipelineEvent<K, ObjectLoaderUploadCompleter.UploadResult<T>>>? = null, completedUploadPartitioner: ObjectLoaderCompletedUploadPartitioner<StreamKey, DestinationRecordRaw, K, T>? = null, taskFactory: LoadPipelineStepTaskFactory): ObjectLoaderOneShotUploaderStep<K, T>