ObjectLoaderOneShotUploaderStep

Constructors

Link copied to clipboard
constructor(objectLoaderOneShotUploader: ObjectLoaderOneShotUploader<*, T>, completedUploadQueue: PartitionedQueue<PipelineEvent<K, ObjectLoaderUploadCompleter.UploadResult<T>>>? = null, completedUploadPartitioner: ObjectLoaderCompletedUploadPartitioner<StreamKey, DestinationRecordRaw, K, T>? = null, taskFactory: LoadPipelineStepTaskFactory, numWorkers: Int)

Properties

Link copied to clipboard
open override val numWorkers: Int

Functions

Link copied to clipboard
open override fun taskForPartition(partition: Int): Task