bulk-cdk-toolkit-load-object-storage/io.airbyte.cdk.load.pipline.object_storage/ObjectLoaderUploadCompleterStep

ObjectLoaderUploadCompleterStep

class ObjectLoaderUploadCompleterStep<K : WithStream, T : RemoteObject<*>>(objectLoader: ObjectLoader, uploadCompleter: ObjectLoaderUploadCompleter<T>, inputQueue: PartitionedQueue<PipelineEvent<ObjectKey, ObjectLoaderPartLoader.PartResult<T>>>, completedUploadQueue: PartitionedQueue<PipelineEvent<K, ObjectLoaderUploadCompleter.UploadResult<T>>>? = null, completedUploadPartitioner: ObjectLoaderCompletedUploadPartitioner<ObjectKey, ObjectLoaderPartLoader.PartResult<T>, K, T>? = null, taskFactory: LoadPipelineStepTaskFactory, stepId: String) : LoadPipelineStep

Constructors

Link copied to clipboard

Properties

Link copied to clipboard
open override val numWorkers: Int

Functions

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