bulk-cdk-toolkit-load-db/io.airbyte.cdk.load.pipeline.db/BulkLoaderLoadIntoTableStep

BulkLoaderLoadIntoTableStep

@Singleton
@Requires(bean = BulkLoaderFactory::class)
class BulkLoaderLoadIntoTableStep<K : WithStream, T : RemoteObject<*>>(val bulkLoader: BulkLoaderFactory<K, T>, val tableLoader: BulkLoaderTableLoader<K, T>, @Named(value = "objectLoaderCompletedUploadQueue") val inputQueue: PartitionedQueue<PipelineEvent<K, ObjectLoaderUploadCompleter.UploadResult<T>>>, val taskFactory: LoadPipelineStepTaskFactory) : LoadPipelineStep

Constructors

Link copied to clipboard
constructor(bulkLoader: BulkLoaderFactory<K, T>, tableLoader: BulkLoaderTableLoader<K, T>, @Named(value = "objectLoaderCompletedUploadQueue") inputQueue: PartitionedQueue<PipelineEvent<K, ObjectLoaderUploadCompleter.UploadResult<T>>>, taskFactory: LoadPipelineStepTaskFactory)

Properties

Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
open override val numWorkers: Int
Link copied to clipboard
Link copied to clipboard

Functions

Link copied to clipboard
open override fun taskForPartition(partition: Int): LoadPipelineStepTask<*, *, *, *, *>