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

filePartLoader

@Named(value = "filePartLoaderStep")
@Singleton
@Requires(condition = IsFileTransferCondition::class)
fun <T : RemoteObject<*>> filePartLoader(loader: ObjectLoader, partLoader: ObjectLoaderPartLoader<T>, @Named(value = "filePartQueue") inputQueue: PartitionedQueue<PipelineEvent<ObjectKey, ObjectLoaderPartFormatter.FormattedPart>>, @Named(value = "fileLoadedPartQueue") outputQueue: PartitionedQueue<PipelineEvent<ObjectKey, ObjectLoaderPartLoader.PartResult<T>>>, taskFactory: LoadPipelineStepTaskFactory): ObjectLoaderPartLoaderStep<T>