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

InsertLoaderRequestExecutorStep

@Singleton
@Requires(bean = InsertLoader::class)
class InsertLoaderRequestExecutorStep<Q : InsertLoaderRequest>(loader: InsertLoader<Q>, requestExecutor: InsertLoaderRequestExecutorAccumulator<Q>, @Named(value = "insertLoaderRequestQueue") inputQueue: PartitionedQueue<PipelineEvent<StreamKey, InsertLoaderRequestBuilderAccumulator.Result<Q>>>, taskFactory: LoadPipelineStepTaskFactory) : LoadPipelineStep

Constructors

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

Properties

Link copied to clipboard
open override val numWorkers: Int

Functions

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