Airbyte Kotlin Bulk CDK

0.1.92

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

DlqNoopAccumulator

class DlqNoopAccumulator : BatchAccumulator<DlqNoopState, StreamKey, DestinationRecordRaw, WithBatchState>

See documentation of DlqNoopPipelineStep.

Constructors

DlqNoopAccumulator

constructor()

Functions

open suspend override fun accept(input: DestinationRecordRaw, state: DlqNoopState): BatchAccumulatorResult<DlqNoopState, WithBatchState>

open suspend override fun finish(state: DlqNoopState): FinalOutput<DlqNoopState, WithBatchState>

open suspend override fun start(key: StreamKey, part: Int): DlqNoopState