Airbyte Kotlin Bulk CDK

0.1.92

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

BulkLoaderTableLoader

@Singleton

@Requires(bean = BulkLoaderFactory::class)

class BulkLoaderTableLoader<K : WithStream, T : RemoteObject<*>>(val bulkLoader: BulkLoaderFactory<K, T>) : BatchAccumulator<BulkLoader<T>, K, ObjectLoaderUploadCompleter.UploadResult<T>, BulkLoaderTableLoader.LoadResult>

Constructors

BulkLoaderTableLoader

constructor(bulkLoader: BulkLoaderFactory<K, T>)

Types

data object LoadResult : WithBatchState

Properties

val bulkLoader: BulkLoaderFactory<K, T>

Functions

open suspend override fun accept(input: ObjectLoaderUploadCompleter.UploadResult<T>, state: BulkLoader<T>): BatchAccumulatorResult<BulkLoader<T>, BulkLoaderTableLoader.LoadResult>

open suspend override fun finish(state: BulkLoader<T>): FinalOutput<BulkLoader<T>, BulkLoaderTableLoader.LoadResult>

open suspend override fun start(key: K, part: Int): BulkLoader<T>