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

recordUploadCompleter

@Named(value = "recordUploadCompleterStep")
@Singleton
fun <K : WithStream, T : RemoteObject<*>> recordUploadCompleter(objectLoader: ObjectLoader, uploadCompleter: ObjectLoaderUploadCompleter<T>, @Named(value = "objectLoaderLoadedPartQueue") inputQueue: PartitionedQueue<PipelineEvent<ObjectKey, ObjectLoaderPartLoader.PartResult<T>>>, @Named(value = "objectLoaderCompletedUploadQueue") completedUploadQueue: PartitionedQueue<PipelineEvent<K, ObjectLoaderUploadCompleter.UploadResult<T>>>? = null, completedUploadPartitioner: ObjectLoaderCompletedUploadPartitioner<ObjectKey, ObjectLoaderPartLoader.PartResult<T>, K, T>? = null, taskFactory: LoadPipelineStepTaskFactory): ObjectLoaderUploadCompleterStep<K, T>