Airbyte Kotlin Bulk CDK

0.1.92

bulk-cdk-toolkit-load-db/io.airbyte.cdk.load.pipeline.db/InsertLoaderRequestBuilderAccumulator

InsertLoaderRequestBuilderAccumulator

@Singleton

@Requires(bean = InsertLoader::class)

class InsertLoaderRequestBuilderAccumulator<Q : InsertLoaderRequest>(loaderFactory: InsertLoader<Q>, @Named(value = "insertLoaderClampedRequestSizeBytes") maxRequestSizeBytes: Long) : BatchAccumulator<InsertLoaderRequestBuilder<Q>, StreamKey, DestinationRecordRaw, InsertLoaderRequestBuilderAccumulator.Result<Q>>

Constructors

InsertLoaderRequestBuilderAccumulator

constructor(loaderFactory: InsertLoader<Q>, @Named(value = "insertLoaderClampedRequestSizeBytes") maxRequestSizeBytes: Long)

Types

data class Result<Q>(val request: Q) : WithBatchState

Functions

open suspend override fun accept(input: DestinationRecordRaw, state: InsertLoaderRequestBuilder<Q>): BatchAccumulatorResult<InsertLoaderRequestBuilder<Q>, InsertLoaderRequestBuilderAccumulator.Result<Q>>

open suspend override fun finish(state: InsertLoaderRequestBuilder<Q>): FinalOutput<InsertLoaderRequestBuilder<Q>, InsertLoaderRequestBuilderAccumulator.Result<Q>>

open suspend override fun start(key: StreamKey, part: Int): InsertLoaderRequestBuilder<Q>