Airbyte Kotlin Bulk CDK

0.1.92

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

InsertLoaderRequestPartitioner

@Singleton

@Requires(bean = InsertLoader::class)

class InsertLoaderRequestPartitioner<Q : InsertLoaderRequest>(val insertLoader: InsertLoader<Q>) : OutputPartitioner<StreamKey, DestinationRecordRaw, StreamKey, InsertLoaderRequestBuilderAccumulator.Result<Q>>

Constructors

InsertLoaderRequestPartitioner

constructor(insertLoader: InsertLoader<Q>)

Properties

val insertLoader: InsertLoader<Q>

Functions

open override fun getOutputKey(inputKey: StreamKey, output: InsertLoaderRequestBuilderAccumulator.Result<Q>): StreamKey

open override fun getPart(outputKey: StreamKey, inputPart: Int, numParts: Int): Int