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

InsertLoaderRequestBuilderStep

@Singleton
@Requires(bean = InsertLoader::class)
class InsertLoaderRequestBuilderStep<Q : InsertLoaderRequest>(val loader: InsertLoader<Q>, val requestBuilder: InsertLoaderRequestBuilderAccumulator<Q>, val taskFactory: LoadPipelineStepTaskFactory, @Named(value = "insertLoaderRequestQueue") val outputQueue: PartitionedQueue<PipelineEvent<StreamKey, InsertLoaderRequestBuilderAccumulator.Result<Q>>>, val outputPartitioner: InsertLoaderRequestPartitioner<Q>) : LoadPipelineStep

Constructors

Link copied to clipboard
constructor(loader: InsertLoader<Q>, requestBuilder: InsertLoaderRequestBuilderAccumulator<Q>, taskFactory: LoadPipelineStepTaskFactory, @Named(value = "insertLoaderRequestQueue") outputQueue: PartitionedQueue<PipelineEvent<StreamKey, InsertLoaderRequestBuilderAccumulator.Result<Q>>>, outputPartitioner: InsertLoaderRequestPartitioner<Q>)

Properties

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

Functions

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