bulk-cdk-toolkit-load-dlq/io.airbyte.cdk.load.pipeline.dlq/DlqLoaderAccumulator

DlqLoaderAccumulator

class DlqLoaderAccumulator<S>(loader: DlqLoader<S>) : BatchAccumulator<S, StreamKey, DestinationRecordRaw, DlqStepOutput>

Wraps a DlqLoader into a BatchAccumulator so that it fits into a LoadPipeline.

Constructors

Link copied to clipboard
constructor(loader: DlqLoader<S>)

Functions

Link copied to clipboard
open suspend override fun accept(input: DestinationRecordRaw, state: S): BatchAccumulatorResult<S, DlqStepOutput>

Propagates the accept call to the DlqLoader.

Link copied to clipboard
open suspend override fun finish(state: S): FinalOutput<S, DlqStepOutput>
Link copied to clipboard
open suspend override fun start(key: StreamKey, part: Int): S

Propagates the call to the DlqLoader in order to create a new state for a stream.