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