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

ObjectLoaderPartFormatterStep

class ObjectLoaderPartFormatterStep(val numWorkers: Int, partFormatter: ObjectLoaderPartFormatter<*>, inputFlows: Array<Flow<PipelineEvent<StreamKey, DestinationRecordRaw>>>, outputQueue: PartitionedQueue<PipelineEvent<ObjectKey, ObjectLoaderPartFormatter.FormattedPart>>, taskFactory: LoadPipelineStepTaskFactory, stepId: String, flushStrategy: PipelineFlushStrategy?) : 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<*, *, *, *, *>