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

fileUploadCompleter

@Named(value = "fileUploadCompleterStep")
@Singleton
@Requires(condition = IsFileTransferCondition::class)
fun <K : WithStream, T : RemoteObject<*>> fileUploadCompleter(objectLoader: ObjectLoader, uploadCompleter: ObjectLoaderUploadCompleter<T>, @Named(value = "fileLoadedPartQueue") inputQueue: PartitionedQueue<PipelineEvent<ObjectKey, ObjectLoaderPartLoader.PartResult<T>>>, @Named(value = "fileCompletedQueue") completedUploadQueue: PartitionedQueue<PipelineEvent<K, ObjectLoaderUploadCompleter.UploadResult<T>>>? = null, @Named(value = "fileCompletedOutputPartitioner") completedUploadPartitioner: ObjectLoaderCompletedUploadPartitioner<ObjectKey, ObjectLoaderPartLoader.PartResult<T>, K, T>? = null, taskFactory: LoadPipelineStepTaskFactory): ObjectLoaderUploadCompleterStep<K, T>