DlqPipelineFactory
class DlqPipelineFactory(dlqInputQueue: PartitionedQueue<PipelineEvent<StreamKey, DestinationRecordRaw>>, dlqPipelineSteps: List<LoadPipelineStep>, pipelineStepTaskFactory: LoadPipelineStepTaskFactory, objectLoader: ObjectLoader)
Factory to build a DeadLetterQueueLoadPipeline.
Constructors
Link copied to clipboard
constructor(dlqInputQueue: PartitionedQueue<PipelineEvent<StreamKey, DestinationRecordRaw>>, dlqPipelineSteps: List<LoadPipelineStep>, pipelineStepTaskFactory: LoadPipelineStepTaskFactory, objectLoader: ObjectLoader)