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

recordPartLoader

@Named(value = "recordPartLoaderStep")
@Singleton
fun <T : RemoteObject<*>> recordPartLoader(loader: ObjectLoader, partLoader: ObjectLoaderPartLoader<T>, @Named(value = "objectLoaderPartQueue") inputQueue: PartitionedQueue<PipelineEvent<ObjectKey, ObjectLoaderPartFormatter.FormattedPart>>, @Named(value = "objectLoaderLoadedPartQueue") outputQueue: PartitionedQueue<PipelineEvent<ObjectKey, ObjectLoaderPartLoader.PartResult<T>>>, taskFactory: LoadPipelineStepTaskFactory): ObjectLoaderPartLoaderStep<T>