bulk-cdk-toolkit-load-object-storage/io.airbyte.cdk.load.pipline.object_storage/ObjectLoaderCompletedUploadPartitioner

ObjectLoaderCompletedUploadPartitioner

interface ObjectLoaderCompletedUploadPartitioner<K1 : WithStream, T, K2 : WithStream, U : RemoteObject<*>> : OutputPartitioner<K1, T, K2, ObjectLoaderUploadCompleter.UploadResult<U>>

Inheritors

Functions

Link copied to clipboard
abstract fun getOutputKey(inputKey: K1, output: ObjectLoaderUploadCompleter.UploadResult<U>): K2
Link copied to clipboard
abstract fun getPart(outputKey: K2, inputPart: Int, numParts: Int): Int