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

ObjectLoaderPartLoaderStep

class ObjectLoaderPartLoaderStep<T : RemoteObject<*>>(loader: ObjectLoader, partLoader: ObjectLoaderPartLoader<T>, inputQueue: PartitionedQueue<PipelineEvent<ObjectKey, ObjectLoaderPartFormatter.FormattedPart>>, outputQueue: PartitionedQueue<PipelineEvent<ObjectKey, ObjectLoaderPartLoader.PartResult<T>>>, taskFactory: LoadPipelineStepTaskFactory, stepId: String) : LoadPipelineStep

Properties

Link copied to clipboard
open override val numWorkers: Int

Functions

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