WithBatchState

Used internally by the CDK to implement Loaders. It is added to outputs of io.airbyte.cdk.load.pipeline.BatchAccumulator that can ack or complete record batches. This is done when stitching the dev interface to the pipeline, so the dev does not have to think about internal state.

Inheritors