Airbyte Kotlin Bulk CDK

0.1.92

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

InsertLoaderRequestExecutorAccumulator

@Singleton

@Requires(bean = InsertLoader::class)

class InsertLoaderRequestExecutorAccumulator<Q : InsertLoaderRequest>(insertLoader: InsertLoader<Q>) : BatchAccumulator<Closeable, StreamKey, InsertLoaderRequestBuilderAccumulator.Result<Q>, InsertLoaderRequestExecutorAccumulator.Result>

Constructors

InsertLoaderRequestExecutorAccumulator

constructor(insertLoader: InsertLoader<Q>)

Types

data object Result : WithBatchState

Functions

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

open suspend override fun finish(state: Closeable): FinalOutput<Closeable, InsertLoaderRequestExecutorAccumulator.Result>

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