ObjectLoaderOneShotUploaderStep

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