bulk-cdk-toolkit-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>

Constructors

Link copied to clipboard
constructor()

Functions

Link copied to clipboard
open override fun getOutputKey(inputKey: K, output: ObjectLoaderUploadCompleter.UploadResult<U>): StreamKey
Link copied to clipboard
open override fun getPart(outputKey: StreamKey, inputPart: Int, numParts: Int): Int