bulk-cdk-toolkit-legacy-task-load-db/io.airbyte.cdk.load.pipeline.db/BulkLoadCompletedUploadPartitioner

BulkLoadCompletedUploadPartitioner

@Singleton

@Secondary

@Requires(bean = BulkLoaderFactory::class)

class BulkLoadCompletedUploadPartitioner<K : WithStream, T, U : RemoteObject<*>> : ObjectLoaderCompletedUploadPartitioner<K, T, StreamKey, U> (source)

Constructors

BulkLoadCompletedUploadPartitioner

constructor()

Functions

open override fun getOutputKey(inputKey: K, output: ObjectLoaderUploadCompleter.UploadResult<U>): StreamKey

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